feat(version): update to orchestrator version v1.1.0

feat(version): updated gomod
feat(version): updated for latest release of the Orchestrator
2024-09-04 20:49:07 +02:00 · 2024-09-01 19:16:10 +02:00 · 2024-09-01 19:15:48 +02:00 · 2024-09-01 18:53:07 +02:00 · 2024-09-01 18:50:40 +02:00
35 changed files with 2669 additions and 1852 deletions
--- a/.idea/runConfigurations/Generate_Code.xml
+++ b/.idea/runConfigurations/Generate_Code.xml
@ -2,24 +2,18 @@
  <configuration default="false" name="Generate Code" type="SwaggerCodegen" editBeforeRun="true" show_console_on_std_err="false" show_console_on_std_out="false">
    <option name="allowRunningInParallel" value="false" />
    <option name="customTemplatesPath" value="" />
-    <option name="envs">
-      <map />
-    </option>
-    <option name="generateToPath" value="C:\Users\SoXX\GolandProjects\anthrove\orchestrator-swagger-go-client" />
+    <option name="generateToPath" value="E:\Anthrove\orchestrator-swagger-go-client" />
    <option name="generationParameters">
      <list />
    </option>
    <option name="generatorType" value="OPENAPI_GENERATOR_V6" />
    <option name="jdkPath" value="C:\Users\SoXX\AppData\Local\Programs\GoLand\jbr\bin\java.exe" />
    <option name="language" value="go" />
-    <option name="passParentEnvs" value="true" />
-    <option name="programParameters" />
    <option name="projectPathOnTarget" />
    <option name="selectedOptions">
      <list />
    </option>
-    <option name="specificationPath" value="C:\Users\SoXX\GolandProjects\anthrove\orchestrator\docs\swagger.yaml" />
-    <option name="workingDirectory" value="C:\Users\SoXX\GolandProjects\anthrove\orchestrator\docs" />
+    <option name="specificationPath" value="E:\Anthrove\orchestrator\docs\swagger.json" />
    <method v="2" />
  </configuration>
 </component>
--- a/.idea/vcs.xml
+++ b/.idea/vcs.xml
@ -1,5 +1,11 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
+  <component name="CommitMessageInspectionProfile">
+    <profile version="1.0">
+      <inspection_tool class="CommitFormat" enabled="true" level="WARNING" enabled_by_default="true" />
+      <inspection_tool class="CommitNamingConvention" enabled="true" level="WARNING" enabled_by_default="true" />
+    </profile>
+  </component>
  <component name="VcsDirectoryMappings">
    <mapping directory="" vcs="Git" />
  </component>
--- a/.openapi-generator/FILES
+++ b/.openapi-generator/FILES
@ -3,22 +3,22 @@
 .travis.yml
 README.md
 api/openapi.yaml
-api_plug.go
 api_user.go
+api_user_message.go
+api_user_source.go
 client.go
 configuration.go
-docs/ModelsOrchestratorTask.md
-docs/ModelsPlugTask.md
-docs/ModelsPlugTaskState.md
-docs/PlugAPI.md
-docs/UserAPI.md
+docs/TaskMessage.md
+docs/TaskResponse.md
+docs/TaskStartTask.md
+docs/UserApi.md
+docs/UserMessageApi.md
+docs/UserSourceApi.md
 git_push.sh
 go.mod
 go.sum
-model_models_orchestrator_task.go
-model_models_plug_task.go
-model_models_plug_task_state.go
+model_task_message.go
+model_task_response.go
+model_task_start_task.go
 response.go
-test/api_plug_test.go
-test/api_user_test.go
 utils.go
--- a/.openapi-generator/VERSION
+++ b/.openapi-generator/VERSION
@ -1 +1 @@
-7.2.0
+6.2.0
--- a/README.md
+++ b/README.md
@ -5,7 +5,7 @@ This service handles the communication between the manager and the plugs
 ## Overview
 This API client was generated by the [OpenAPI Generator](https://openapi-generator.tech) project.  By using the [OpenAPI-spec](https://www.openapis.org/) from a remote server, you can easily generate an API client.

- API version: 0.1-PREVIEW
+- API version: 1.0
 - Package version: 1.0.0
 - Build package: org.openapitools.codegen.languages.GoClientCodegen
 For more information, please visit [http://anthrove.art/support](http://anthrove.art/support)
@ -14,20 +14,21 @@ For more information, please visit [http://anthrove.art/support](http://anthrove

 Install the following dependencies:

-```sh
+```shell
 go get github.com/stretchr/testify/assert
+go get golang.org/x/oauth2
 go get golang.org/x/net/context
 ```

 Put the package under your project folder and add the following in import:

-```go
+```golang
 import openapi "git.anthrove.art/Anthrove/orchestrator-swagger-go-client"
 ```

 To use a proxy, set the environment variable `HTTP_PROXY`:

-```go
+```golang
 os.Setenv("HTTP_PROXY", "http://proxy_name:proxy_port")
 ```

@ -37,17 +38,17 @@ Default configuration comes with `Servers` field that contains server objects as

 ### Select Server Configuration

-For using other server than the one defined on index 0 set context value `openapi.ContextServerIndex` of type `int`.
+For using other server than the one defined on index 0 set context value `sw.ContextServerIndex` of type `int`.

-```go
+```golang
 ctx := context.WithValue(context.Background(), openapi.ContextServerIndex, 1)
 ```

 ### Templated Server URL

-Templated server URL is formatted using default variables from configuration or from context value `openapi.ContextServerVariables` of type `map[string]string`.
+Templated server URL is formatted using default variables from configuration or from context value `sw.ContextServerVariables` of type `map[string]string`.

-```go
+```golang
 ctx := context.WithValue(context.Background(), openapi.ContextServerVariables, map[string]string{
 	"basePath": "v2",
 })
@ -59,9 +60,9 @@ Note, enum values are always validated and all unused variables are silently ign

 Each operation can use different server URL defined using `OperationServers` map in the `Configuration`.
 An operation is uniquely identified by `"{classname}Service.{nickname}"` string.
-Similar rules for overriding default operation server index and variables applies by using `openapi.ContextOperationServerIndices` and `openapi.ContextOperationServerVariables` context maps.
+Similar rules for overriding default operation server index and variables applies by using `sw.ContextOperationServerIndices` and `sw.ContextOperationServerVariables` context maps.

-```go
+```golang
 ctx := context.WithValue(context.Background(), openapi.ContextOperationServerIndices, map[string]int{
 	"{classname}Service.{nickname}": 2,
 })
@ -78,17 +79,19 @@ All URIs are relative to */api/v1*

 Class | Method | HTTP request | Description
 ------------ | ------------- | ------------- | -------------
-*PlugAPI* | [**PlugPlugTypePut**](docs/PlugAPI.md#plugplugtypeput) | **Put** /plug/{plug_type} | Initiates a scraping operation for a user with a specific plug type
-*PlugAPI* | [**PlugPlugTypeTaskIdDelete**](docs/PlugAPI.md#plugplugtypetaskiddelete) | **Delete** /plug/{plug_type}/{task_id} | Stops a scraping operation for a user with a specific plug type
-*PlugAPI* | [**PlugPlugTypeTaskIdGet**](docs/PlugAPI.md#plugplugtypetaskidget) | **Get** /plug/{plug_type}/{task_id} | Retrieves the status of a specific task type
-*UserAPI* | [**UserUserIdPut**](docs/UserAPI.md#useruseridput) | **Put** /user/{user_id} | Initiates a scraping operation for the entire user
+*UserApi* | [**UserTaskPost**](docs/UserApi.md#usertaskpost) | **Post** /user/task | Start scraping all user sources
+*UserApi* | [**UserTaskUserIdGet**](docs/UserApi.md#usertaskuseridget) | **Get** /user/task/{user_id} | Gets all tasks of a user
+*UserMessageApi* | [**PlugMessagesPlugIdentifierUserSourceIdGet**](docs/UserMessageApi.md#plugmessagesplugidentifierusersourceidget) | **Get** /plug/messages/{plug_identifier}/{user_source_id} | Get all Messages from a user
+*UserSourceApi* | [**PlugTaskPlugIdentifierPost**](docs/UserSourceApi.md#plugtaskplugidentifierpost) | **Post** /plug/task/{plug_identifier} | Start a plug task
+*UserSourceApi* | [**PlugTaskPlugIdentifierTaskIdDelete**](docs/UserSourceApi.md#plugtaskplugidentifiertaskiddelete) | **Delete** /plug/task/{plug_identifier}/{task_id} | Stop a plug task
+*UserSourceApi* | [**PlugTaskPlugIdentifierTaskIdGet**](docs/UserSourceApi.md#plugtaskplugidentifiertaskidget) | **Get** /plug/task/{plug_identifier}/{task_id} | Gets the status of a plug task


 ## Documentation For Models

- - [ModelsOrchestratorTask](docs/ModelsOrchestratorTask.md)
- - [ModelsPlugTask](docs/ModelsPlugTask.md)
- - [ModelsPlugTaskState](docs/ModelsPlugTaskState.md)
+ - [TaskMessage](docs/TaskMessage.md)
+ - [TaskResponse](docs/TaskResponse.md)
+ - [TaskStartTask](docs/TaskStartTask.md)


 ## Documentation For Authorization
--- a/api/openapi.yaml
+++ b/api/openapi.yaml
@ -7,54 +7,89 @@ info:
  description: This service handles the communication between the manager and the
    plugs
  title: Anthrove Orchestrator API
-  version: 0.1-PREVIEW
+  version: "1.0"
 servers:
 - url: /api/v1
 paths:
-  /plug/{plug_type}:
-    put:
-      description: Initiates a scraping operation for a user with a specific plug
-        type returns the created task IDs.
+  /plug/messages/{plug_identifier}/{user_source_id}:
+    get:
+      description: Retrieves all user messages from a specific plug
      parameters:
-      - description: supported plug type
+      - description: User Source ID
        in: path
-        name: plug_type
+        name: user_source_id
+        required: true
+        schema:
+          type: string
+      - description: Plug Identifier
+        in: path
+        name: plug_identifier
+        required: true
+        schema:
+          type: string
+      responses:
+        "200":
+          content:
+            '*/*':
+              schema:
+                items:
+                  $ref: '#/components/schemas/task.Message'
+                type: array
+          description: OK
+        "400":
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/gin.H'
+          description: Bad Request
+      summary: Get all Messages from a user
+      tags:
+      - User Message
+  /plug/task/{plug_identifier}:
+    post:
+      description: Starts a task for the specified plug
+      parameters:
+      - description: Plug Identifier
+        in: path
+        name: plug_identifier
        required: true
        schema:
          type: string
      requestBody:
        content:
-          application/json:
+          '*/*':
            schema:
-              $ref: '#/components/schemas/models.OrchestratorTask'
-        description: aa
+              $ref: '#/components/schemas/task.StartTask'
+        description: Task Details
        required: true
      responses:
        "200":
-          content: {}
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/task.Response'
          description: OK
-        "404":
-          content: {}
-          description: Not Found
-        "500":
-          content: {}
-          description: Internal Server Error
-      summary: Initiates a scraping operation for a user with a specific plug type
+        "400":
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/gin.H'
+          description: Bad Request
+      summary: Start a plug task
      tags:
-      - Plug
-      x-codegen-request-body-name: request
-  /plug/{plug_type}/{task_id}:
+      - UserSource
+      x-codegen-request-body-name: task
+  /plug/task/{plug_identifier}/{task_id}:
    delete:
-      description: Stops a scraping operation for a user with a specific plug type
-        returns the created task IDs.
+      description: Stops a task for the specified plug
      parameters:
-      - description: supported plug type
+      - description: Plug Identifier
        in: path
-        name: plug_type
+        name: plug_identifier
        required: true
        schema:
          type: string
-      - description: id of task
+      - description: Task ID
        in: path
        name: task_id
        required: true
@ -62,27 +97,30 @@ paths:
          type: string
      responses:
        "200":
-          content: {}
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/task.Response'
          description: OK
-        "404":
-          content: {}
-          description: Not Found
-        "500":
-          content: {}
-          description: Internal Server Error
-      summary: Stops a scraping operation for a user with a specific plug type
+        "400":
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/gin.H'
+          description: Bad Request
+      summary: Stop a plug task
      tags:
-      - Plug
+      - UserSource
    get:
-      description: Retrieves the status of a specific task and returns it.
+      description: Retrieves the status of a task for the specified plug
      parameters:
-      - description: supported plug type
+      - description: Plug Identifier
        in: path
-        name: plug_type
+        name: plug_identifier
        required: true
        schema:
          type: string
-      - description: id of task
+      - description: Task ID
        in: path
        name: task_id
        required: true
@ -90,23 +128,48 @@ paths:
          type: string
      responses:
        "200":
-          content: {}
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/task.Response'
          description: OK
-        "404":
-          content: {}
-          description: Not Found
-        "500":
-          content: {}
-          description: Internal Server Error
-      summary: Retrieves the status of a specific task type
+        "400":
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/gin.H'
+          description: Bad Request
+      summary: Gets the status of a plug task
      tags:
-      - Plug
-  /user/{user_id}:
-    put:
-      description: Initiates a scraping operation for the entire user and returns
-        the created task IDs.
+      - UserSource
+  /user/task:
+    post:
+      description: Starts a task to scrape all user sources
+      responses:
+        "200":
+          content:
+            '*/*':
+              schema:
+                items:
+                  items:
+                    $ref: '#/components/schemas/task.Response'
+                  type: array
+                type: array
+          description: OK
+        "500":
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/gin.H'
+          description: Internal Server Error
+      summary: Start scraping all user sources
+      tags:
+      - User
+  /user/task/{user_id}:
+    get:
+      description: Retrieves the status of a task for the specified plug
      parameters:
-      - description: Anthrove UserID
+      - description: User ID
        in: path
        name: user_id
        required: true
@ -114,53 +177,61 @@ paths:
          type: string
      responses:
        "200":
-          content: {}
+          content:
+            '*/*':
+              schema:
+                items:
+                  $ref: '#/components/schemas/task.Response'
+                type: array
          description: OK
-        "404":
-          content: {}
-          description: Not Found
-        "500":
-          content: {}
-          description: Internal Server Error
-      summary: Initiates a scraping operation for the entire user
+        "400":
+          content:
+            '*/*':
+              schema:
+                $ref: '#/components/schemas/gin.H'
+          description: Bad Request
+      summary: Gets all tasks of a user
      tags:
      - User
 components:
  schemas:
-    models.OrchestratorTask:
-      properties:
-        anthrove_user_id:
-          type: string
-        deep_scrape:
-          type: boolean
-        plug_task:
-          $ref: '#/components/schemas/models.PlugTask'
-      required:
-      - anthrove_user_id
-      - deep_scrape
-      - plug_task
+    gin.H:
+      additionalProperties:
        type: object
-    models.PlugTask:
+      type: object
+    task.Message:
+      example:
+        user_source_id: user_source_id
+        created_at: created_at
+        body: body
+        title: title
      properties:
-        id:
+        body:
+          type: string
+        created_at:
+          type: string
+        title:
+          type: string
+        user_source_id:
+          type: string
+      type: object
+    task.Response:
+      example:
+        plug_task_id: plug_task_id
+        plug_task_status: plug_task_status
+      properties:
+        plug_task_id:
+          type: string
+        plug_task_status:
+          type: string
+      type: object
+    task.StartTask:
+      properties:
+        user_api_key:
          type: string
-        task_state:
-          $ref: '#/components/schemas/models.PlugTaskState'
        user_id:
          type: string
-      required:
-      - user_id
-      type: object
-    models.PlugTaskState:
-      enum:
-      - UNKNOWN
-      - STARTED
-      - RUNNING
-      - STOPPED
+        user_source_id:
          type: string
-      x-enum-varnames:
-      - PlugTaskStateUnknown
-      - PlugTaskStateStarted
-      - PlugTaskStateRunning
-      - PlugTaskStateStopped
+      type: object
 x-original-swagger-version: "2.0"
--- a/api_plug.go
+++ b/api_plug.go
@ -1,320 +0,0 @@
-/*
-Anthrove Orchestrator API
-
-This service handles the communication between the manager and the plugs
-
-API version: 0.1-PREVIEW
-Contact: support@anthrove.art
-*/
-
-// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
-
-package openapi
-
-import (
-	"bytes"
-	"context"
-	"io"
-	"net/http"
-	"net/url"
-	"strings"
-)
-
-// PlugAPIService PlugAPI service
-type PlugAPIService service
-
-type ApiPlugPlugTypePutRequest struct {
-	ctx        context.Context
-	ApiService *PlugAPIService
-	plugType   string
-	request    *ModelsOrchestratorTask
-}
-
-// aa
-func (r ApiPlugPlugTypePutRequest) Request(request ModelsOrchestratorTask) ApiPlugPlugTypePutRequest {
-	r.request = &request
-	return r
-}
-
-func (r ApiPlugPlugTypePutRequest) Execute() (*http.Response, error) {
-	return r.ApiService.PlugPlugTypePutExecute(r)
-}
-
-/*
-PlugPlugTypePut Initiates a scraping operation for a user with a specific plug type
-
-Initiates a scraping operation for a user with a specific plug type returns the created task IDs.
-
-	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
-	@param plugType supported plug type
-	@return ApiPlugPlugTypePutRequest
-*/
-func (a *PlugAPIService) PlugPlugTypePut(ctx context.Context, plugType string) ApiPlugPlugTypePutRequest {
-	return ApiPlugPlugTypePutRequest{
-		ApiService: a,
-		ctx:        ctx,
-		plugType:   plugType,
-	}
-}
-
-// Execute executes the request
-func (a *PlugAPIService) PlugPlugTypePutExecute(r ApiPlugPlugTypePutRequest) (*http.Response, error) {
-	var (
-		localVarHTTPMethod = http.MethodPut
-		localVarPostBody   interface{}
-		formFiles          []formFile
-	)
-
-	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "PlugAPIService.PlugPlugTypePut")
-	if err != nil {
-		return nil, &GenericOpenAPIError{error: err.Error()}
-	}
-
-	localVarPath := localBasePath + "/plug/{plug_type}"
-	localVarPath = strings.Replace(localVarPath, "{"+"plug_type"+"}", url.PathEscape(parameterValueToString(r.plugType, "plugType")), -1)
-
-	localVarHeaderParams := make(map[string]string)
-	localVarQueryParams := url.Values{}
-	localVarFormParams := url.Values{}
-	if r.request == nil {
-		return nil, reportError("request is required and must be specified")
-	}
-
-	// to determine the Content-Type header
-	localVarHTTPContentTypes := []string{"application/json"}
-
-	// set Content-Type header
-	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
-	if localVarHTTPContentType != "" {
-		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
-	}
-
-	// to determine the Accept header
-	localVarHTTPHeaderAccepts := []string{}
-
-	// set Accept header
-	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
-	if localVarHTTPHeaderAccept != "" {
-		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
-	}
-	// body params
-	localVarPostBody = r.request
-	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
-	if err != nil {
-		return nil, err
-	}
-
-	localVarHTTPResponse, err := a.client.callAPI(req)
-	if err != nil || localVarHTTPResponse == nil {
-		return localVarHTTPResponse, err
-	}
-
-	localVarBody, err := io.ReadAll(localVarHTTPResponse.Body)
-	localVarHTTPResponse.Body.Close()
-	localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody))
-	if err != nil {
-		return localVarHTTPResponse, err
-	}
-
-	if localVarHTTPResponse.StatusCode >= 300 {
-		newErr := &GenericOpenAPIError{
-			body:  localVarBody,
-			error: localVarHTTPResponse.Status,
-		}
-		return localVarHTTPResponse, newErr
-	}
-
-	return localVarHTTPResponse, nil
-}
-
-type ApiPlugPlugTypeTaskIdDeleteRequest struct {
-	ctx        context.Context
-	ApiService *PlugAPIService
-	plugType   string
-	taskId     string
-}
-
-func (r ApiPlugPlugTypeTaskIdDeleteRequest) Execute() (*http.Response, error) {
-	return r.ApiService.PlugPlugTypeTaskIdDeleteExecute(r)
-}
-
-/*
-PlugPlugTypeTaskIdDelete Stops a scraping operation for a user with a specific plug type
-
-Stops a scraping operation for a user with a specific plug type returns the created task IDs.
-
-	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
-	@param plugType supported plug type
-	@param taskId id of task
-	@return ApiPlugPlugTypeTaskIdDeleteRequest
-*/
-func (a *PlugAPIService) PlugPlugTypeTaskIdDelete(ctx context.Context, plugType string, taskId string) ApiPlugPlugTypeTaskIdDeleteRequest {
-	return ApiPlugPlugTypeTaskIdDeleteRequest{
-		ApiService: a,
-		ctx:        ctx,
-		plugType:   plugType,
-		taskId:     taskId,
-	}
-}
-
-// Execute executes the request
-func (a *PlugAPIService) PlugPlugTypeTaskIdDeleteExecute(r ApiPlugPlugTypeTaskIdDeleteRequest) (*http.Response, error) {
-	var (
-		localVarHTTPMethod = http.MethodDelete
-		localVarPostBody   interface{}
-		formFiles          []formFile
-	)
-
-	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "PlugAPIService.PlugPlugTypeTaskIdDelete")
-	if err != nil {
-		return nil, &GenericOpenAPIError{error: err.Error()}
-	}
-
-	localVarPath := localBasePath + "/plug/{plug_type}/{task_id}"
-	localVarPath = strings.Replace(localVarPath, "{"+"plug_type"+"}", url.PathEscape(parameterValueToString(r.plugType, "plugType")), -1)
-	localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterValueToString(r.taskId, "taskId")), -1)
-
-	localVarHeaderParams := make(map[string]string)
-	localVarQueryParams := url.Values{}
-	localVarFormParams := url.Values{}
-
-	// to determine the Content-Type header
-	localVarHTTPContentTypes := []string{}
-
-	// set Content-Type header
-	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
-	if localVarHTTPContentType != "" {
-		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
-	}
-
-	// to determine the Accept header
-	localVarHTTPHeaderAccepts := []string{}
-
-	// set Accept header
-	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
-	if localVarHTTPHeaderAccept != "" {
-		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
-	}
-	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
-	if err != nil {
-		return nil, err
-	}
-
-	localVarHTTPResponse, err := a.client.callAPI(req)
-	if err != nil || localVarHTTPResponse == nil {
-		return localVarHTTPResponse, err
-	}
-
-	localVarBody, err := io.ReadAll(localVarHTTPResponse.Body)
-	localVarHTTPResponse.Body.Close()
-	localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody))
-	if err != nil {
-		return localVarHTTPResponse, err
-	}
-
-	if localVarHTTPResponse.StatusCode >= 300 {
-		newErr := &GenericOpenAPIError{
-			body:  localVarBody,
-			error: localVarHTTPResponse.Status,
-		}
-		return localVarHTTPResponse, newErr
-	}
-
-	return localVarHTTPResponse, nil
-}
-
-type ApiPlugPlugTypeTaskIdGetRequest struct {
-	ctx        context.Context
-	ApiService *PlugAPIService
-	plugType   string
-	taskId     string
-}
-
-func (r ApiPlugPlugTypeTaskIdGetRequest) Execute() (*http.Response, error) {
-	return r.ApiService.PlugPlugTypeTaskIdGetExecute(r)
-}
-
-/*
-PlugPlugTypeTaskIdGet Retrieves the status of a specific task type
-
-Retrieves the status of a specific task and returns it.
-
-	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
-	@param plugType supported plug type
-	@param taskId id of task
-	@return ApiPlugPlugTypeTaskIdGetRequest
-*/
-func (a *PlugAPIService) PlugPlugTypeTaskIdGet(ctx context.Context, plugType string, taskId string) ApiPlugPlugTypeTaskIdGetRequest {
-	return ApiPlugPlugTypeTaskIdGetRequest{
-		ApiService: a,
-		ctx:        ctx,
-		plugType:   plugType,
-		taskId:     taskId,
-	}
-}
-
-// Execute executes the request
-func (a *PlugAPIService) PlugPlugTypeTaskIdGetExecute(r ApiPlugPlugTypeTaskIdGetRequest) (*http.Response, error) {
-	var (
-		localVarHTTPMethod = http.MethodGet
-		localVarPostBody   interface{}
-		formFiles          []formFile
-	)
-
-	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "PlugAPIService.PlugPlugTypeTaskIdGet")
-	if err != nil {
-		return nil, &GenericOpenAPIError{error: err.Error()}
-	}
-
-	localVarPath := localBasePath + "/plug/{plug_type}/{task_id}"
-	localVarPath = strings.Replace(localVarPath, "{"+"plug_type"+"}", url.PathEscape(parameterValueToString(r.plugType, "plugType")), -1)
-	localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterValueToString(r.taskId, "taskId")), -1)
-
-	localVarHeaderParams := make(map[string]string)
-	localVarQueryParams := url.Values{}
-	localVarFormParams := url.Values{}
-
-	// to determine the Content-Type header
-	localVarHTTPContentTypes := []string{}
-
-	// set Content-Type header
-	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
-	if localVarHTTPContentType != "" {
-		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
-	}
-
-	// to determine the Accept header
-	localVarHTTPHeaderAccepts := []string{}
-
-	// set Accept header
-	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
-	if localVarHTTPHeaderAccept != "" {
-		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
-	}
-	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
-	if err != nil {
-		return nil, err
-	}
-
-	localVarHTTPResponse, err := a.client.callAPI(req)
-	if err != nil || localVarHTTPResponse == nil {
-		return localVarHTTPResponse, err
-	}
-
-	localVarBody, err := io.ReadAll(localVarHTTPResponse.Body)
-	localVarHTTPResponse.Body.Close()
-	localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody))
-	if err != nil {
-		return localVarHTTPResponse, err
-	}
-
-	if localVarHTTPResponse.StatusCode >= 300 {
-		newErr := &GenericOpenAPIError{
-			body:  localVarBody,
-			error: localVarHTTPResponse.Status,
-		}
-		return localVarHTTPResponse, newErr
-	}
-
-	return localVarHTTPResponse, nil
-}
--- a/api_user.go
+++ b/api_user.go
@ -3,7 +3,7 @@ Anthrove Orchestrator API

 This service handles the communication between the manager and the plugs

-API version: 0.1-PREVIEW
+API version: 1.0
 Contact: support@anthrove.art
 */

@ -14,57 +14,56 @@ package openapi
 import (
 	"bytes"
 	"context"
-	"io"
+	"io/ioutil"
 	"net/http"
 	"net/url"
 	"strings"
 )

-// UserAPIService UserAPI service
-type UserAPIService service
+// UserApiService UserApi service
+type UserApiService service

-type ApiUserUserIdPutRequest struct {
+type ApiUserTaskPostRequest struct {
 	ctx        context.Context
-	ApiService *UserAPIService
-	userId     string
+	ApiService *UserApiService
 }

-func (r ApiUserUserIdPutRequest) Execute() (*http.Response, error) {
-	return r.ApiService.UserUserIdPutExecute(r)
+func (r ApiUserTaskPostRequest) Execute() ([][]TaskResponse, *http.Response, error) {
+	return r.ApiService.UserTaskPostExecute(r)
 }

 /*
-UserUserIdPut Initiates a scraping operation for the entire user
+UserTaskPost Start scraping all user sources

-Initiates a scraping operation for the entire user and returns the created task IDs.
+Starts a task to scrape all user sources

 	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
-	@param userId Anthrove UserID
-	@return ApiUserUserIdPutRequest
+	@return ApiUserTaskPostRequest
 */
-func (a *UserAPIService) UserUserIdPut(ctx context.Context, userId string) ApiUserUserIdPutRequest {
-	return ApiUserUserIdPutRequest{
+func (a *UserApiService) UserTaskPost(ctx context.Context) ApiUserTaskPostRequest {
+	return ApiUserTaskPostRequest{
 		ApiService: a,
 		ctx:        ctx,
-		userId:     userId,
 	}
 }

 // Execute executes the request
-func (a *UserAPIService) UserUserIdPutExecute(r ApiUserUserIdPutRequest) (*http.Response, error) {
+//
+//	@return [][]TaskResponse
+func (a *UserApiService) UserTaskPostExecute(r ApiUserTaskPostRequest) ([][]TaskResponse, *http.Response, error) {
 	var (
-		localVarHTTPMethod = http.MethodPut
+		localVarHTTPMethod  = http.MethodPost
 		localVarPostBody    interface{}
 		formFiles           []formFile
+		localVarReturnValue [][]TaskResponse
 	)

-	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserAPIService.UserUserIdPut")
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserApiService.UserTaskPost")
 	if err != nil {
-		return nil, &GenericOpenAPIError{error: err.Error()}
+		return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()}
 	}

-	localVarPath := localBasePath + "/user/{user_id}"
-	localVarPath = strings.Replace(localVarPath, "{"+"user_id"+"}", url.PathEscape(parameterValueToString(r.userId, "userId")), -1)
+	localVarPath := localBasePath + "/user/task"

 	localVarHeaderParams := make(map[string]string)
 	localVarQueryParams := url.Values{}
@ -80,7 +79,7 @@ func (a *UserAPIService) UserUserIdPutExecute(r ApiUserUserIdPutRequest) (*http.
 	}

 	// to determine the Accept header
-	localVarHTTPHeaderAccepts := []string{}
+	localVarHTTPHeaderAccepts := []string{"*/*"}

 	// set Accept header
 	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
@ -89,19 +88,19 @@ func (a *UserAPIService) UserUserIdPutExecute(r ApiUserUserIdPutRequest) (*http.
 	}
 	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
 	if err != nil {
-		return nil, err
+		return localVarReturnValue, nil, err
 	}

 	localVarHTTPResponse, err := a.client.callAPI(req)
 	if err != nil || localVarHTTPResponse == nil {
-		return localVarHTTPResponse, err
+		return localVarReturnValue, localVarHTTPResponse, err
 	}

-	localVarBody, err := io.ReadAll(localVarHTTPResponse.Body)
+	localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body)
 	localVarHTTPResponse.Body.Close()
-	localVarHTTPResponse.Body = io.NopCloser(bytes.NewBuffer(localVarBody))
+	localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody))
 	if err != nil {
-		return localVarHTTPResponse, err
+		return localVarReturnValue, localVarHTTPResponse, err
 	}

 	if localVarHTTPResponse.StatusCode >= 300 {
@ -109,8 +108,139 @@ func (a *UserAPIService) UserUserIdPutExecute(r ApiUserUserIdPutRequest) (*http.
 			body:  localVarBody,
 			error: localVarHTTPResponse.Status,
 		}
-		return localVarHTTPResponse, newErr
+		if localVarHTTPResponse.StatusCode == 500 {
+			var v map[string]map[string]interface{}
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = err.Error()
+				return localVarReturnValue, localVarHTTPResponse, newErr
+			}
+			newErr.model = v
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
 	}

-	return localVarHTTPResponse, nil
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: err.Error(),
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	return localVarReturnValue, localVarHTTPResponse, nil
+}
+
+type ApiUserTaskUserIdGetRequest struct {
+	ctx        context.Context
+	ApiService *UserApiService
+	userId     string
+}
+
+func (r ApiUserTaskUserIdGetRequest) Execute() ([]TaskResponse, *http.Response, error) {
+	return r.ApiService.UserTaskUserIdGetExecute(r)
+}
+
+/*
+UserTaskUserIdGet Gets all tasks of a user
+
+Retrieves the status of a task for the specified plug
+
+	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	@param userId User ID
+	@return ApiUserTaskUserIdGetRequest
+*/
+func (a *UserApiService) UserTaskUserIdGet(ctx context.Context, userId string) ApiUserTaskUserIdGetRequest {
+	return ApiUserTaskUserIdGetRequest{
+		ApiService: a,
+		ctx:        ctx,
+		userId:     userId,
+	}
+}
+
+// Execute executes the request
+//
+//	@return []TaskResponse
+func (a *UserApiService) UserTaskUserIdGetExecute(r ApiUserTaskUserIdGetRequest) ([]TaskResponse, *http.Response, error) {
+	var (
+		localVarHTTPMethod  = http.MethodGet
+		localVarPostBody    interface{}
+		formFiles           []formFile
+		localVarReturnValue []TaskResponse
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserApiService.UserTaskUserIdGet")
+	if err != nil {
+		return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/user/task/{user_id}"
+	localVarPath = strings.Replace(localVarPath, "{"+"user_id"+"}", url.PathEscape(parameterToString(r.userId, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := url.Values{}
+	localVarFormParams := url.Values{}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"*/*"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
+	if err != nil {
+		return localVarReturnValue, nil, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body)
+	localVarHTTPResponse.Body.Close()
+	localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody))
+	if err != nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: localVarHTTPResponse.Status,
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v map[string]map[string]interface{}
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = err.Error()
+				return localVarReturnValue, localVarHTTPResponse, newErr
+			}
+			newErr.model = v
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: err.Error(),
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	return localVarReturnValue, localVarHTTPResponse, nil
 }
--- a/api_user_message.go
+++ b/api_user_message.go
@ -0,0 +1,141 @@
+/*
+Anthrove Orchestrator API
+
+This service handles the communication between the manager and the plugs
+
+API version: 1.0
+Contact: support@anthrove.art
+*/
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package openapi
+
+import (
+	"bytes"
+	"context"
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"strings"
+)
+
+// UserMessageApiService UserMessageApi service
+type UserMessageApiService service
+
+type ApiPlugMessagesPlugIdentifierUserSourceIdGetRequest struct {
+	ctx            context.Context
+	ApiService     *UserMessageApiService
+	userSourceId   string
+	plugIdentifier string
+}
+
+func (r ApiPlugMessagesPlugIdentifierUserSourceIdGetRequest) Execute() ([]TaskMessage, *http.Response, error) {
+	return r.ApiService.PlugMessagesPlugIdentifierUserSourceIdGetExecute(r)
+}
+
+/*
+PlugMessagesPlugIdentifierUserSourceIdGet Get all Messages from a user
+
+Retrieves all user messages from a specific plug
+
+	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	@param userSourceId User Source ID
+	@param plugIdentifier Plug Identifier
+	@return ApiPlugMessagesPlugIdentifierUserSourceIdGetRequest
+*/
+func (a *UserMessageApiService) PlugMessagesPlugIdentifierUserSourceIdGet(ctx context.Context, userSourceId string, plugIdentifier string) ApiPlugMessagesPlugIdentifierUserSourceIdGetRequest {
+	return ApiPlugMessagesPlugIdentifierUserSourceIdGetRequest{
+		ApiService:     a,
+		ctx:            ctx,
+		userSourceId:   userSourceId,
+		plugIdentifier: plugIdentifier,
+	}
+}
+
+// Execute executes the request
+//
+//	@return []TaskMessage
+func (a *UserMessageApiService) PlugMessagesPlugIdentifierUserSourceIdGetExecute(r ApiPlugMessagesPlugIdentifierUserSourceIdGetRequest) ([]TaskMessage, *http.Response, error) {
+	var (
+		localVarHTTPMethod  = http.MethodGet
+		localVarPostBody    interface{}
+		formFiles           []formFile
+		localVarReturnValue []TaskMessage
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserMessageApiService.PlugMessagesPlugIdentifierUserSourceIdGet")
+	if err != nil {
+		return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/plug/messages/{plug_identifier}/{user_source_id}"
+	localVarPath = strings.Replace(localVarPath, "{"+"user_source_id"+"}", url.PathEscape(parameterToString(r.userSourceId, "")), -1)
+	localVarPath = strings.Replace(localVarPath, "{"+"plug_identifier"+"}", url.PathEscape(parameterToString(r.plugIdentifier, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := url.Values{}
+	localVarFormParams := url.Values{}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"*/*"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
+	if err != nil {
+		return localVarReturnValue, nil, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body)
+	localVarHTTPResponse.Body.Close()
+	localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody))
+	if err != nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: localVarHTTPResponse.Status,
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v map[string]map[string]interface{}
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = err.Error()
+				return localVarReturnValue, localVarHTTPResponse, newErr
+			}
+			newErr.model = v
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: err.Error(),
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	return localVarReturnValue, localVarHTTPResponse, nil
+}
--- a/api_user_source.go
+++ b/api_user_source.go
@ -0,0 +1,383 @@
+/*
+Anthrove Orchestrator API
+
+This service handles the communication between the manager and the plugs
+
+API version: 1.0
+Contact: support@anthrove.art
+*/
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package openapi
+
+import (
+	"bytes"
+	"context"
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"strings"
+)
+
+// UserSourceApiService UserSourceApi service
+type UserSourceApiService service
+
+type ApiPlugTaskPlugIdentifierPostRequest struct {
+	ctx            context.Context
+	ApiService     *UserSourceApiService
+	plugIdentifier string
+	task           *TaskStartTask
+}
+
+// Task Details
+func (r ApiPlugTaskPlugIdentifierPostRequest) Task(task TaskStartTask) ApiPlugTaskPlugIdentifierPostRequest {
+	r.task = &task
+	return r
+}
+
+func (r ApiPlugTaskPlugIdentifierPostRequest) Execute() (*TaskResponse, *http.Response, error) {
+	return r.ApiService.PlugTaskPlugIdentifierPostExecute(r)
+}
+
+/*
+PlugTaskPlugIdentifierPost Start a plug task
+
+Starts a task for the specified plug
+
+	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	@param plugIdentifier Plug Identifier
+	@return ApiPlugTaskPlugIdentifierPostRequest
+*/
+func (a *UserSourceApiService) PlugTaskPlugIdentifierPost(ctx context.Context, plugIdentifier string) ApiPlugTaskPlugIdentifierPostRequest {
+	return ApiPlugTaskPlugIdentifierPostRequest{
+		ApiService:     a,
+		ctx:            ctx,
+		plugIdentifier: plugIdentifier,
+	}
+}
+
+// Execute executes the request
+//
+//	@return TaskResponse
+func (a *UserSourceApiService) PlugTaskPlugIdentifierPostExecute(r ApiPlugTaskPlugIdentifierPostRequest) (*TaskResponse, *http.Response, error) {
+	var (
+		localVarHTTPMethod  = http.MethodPost
+		localVarPostBody    interface{}
+		formFiles           []formFile
+		localVarReturnValue *TaskResponse
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserSourceApiService.PlugTaskPlugIdentifierPost")
+	if err != nil {
+		return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/plug/task/{plug_identifier}"
+	localVarPath = strings.Replace(localVarPath, "{"+"plug_identifier"+"}", url.PathEscape(parameterToString(r.plugIdentifier, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := url.Values{}
+	localVarFormParams := url.Values{}
+	if r.task == nil {
+		return localVarReturnValue, nil, reportError("task is required and must be specified")
+	}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"*/*"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	// body params
+	localVarPostBody = r.task
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
+	if err != nil {
+		return localVarReturnValue, nil, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body)
+	localVarHTTPResponse.Body.Close()
+	localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody))
+	if err != nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: localVarHTTPResponse.Status,
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v map[string]map[string]interface{}
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = err.Error()
+				return localVarReturnValue, localVarHTTPResponse, newErr
+			}
+			newErr.model = v
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: err.Error(),
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	return localVarReturnValue, localVarHTTPResponse, nil
+}
+
+type ApiPlugTaskPlugIdentifierTaskIdDeleteRequest struct {
+	ctx            context.Context
+	ApiService     *UserSourceApiService
+	plugIdentifier string
+	taskId         string
+}
+
+func (r ApiPlugTaskPlugIdentifierTaskIdDeleteRequest) Execute() (*TaskResponse, *http.Response, error) {
+	return r.ApiService.PlugTaskPlugIdentifierTaskIdDeleteExecute(r)
+}
+
+/*
+PlugTaskPlugIdentifierTaskIdDelete Stop a plug task
+
+Stops a task for the specified plug
+
+	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	@param plugIdentifier Plug Identifier
+	@param taskId Task ID
+	@return ApiPlugTaskPlugIdentifierTaskIdDeleteRequest
+*/
+func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdDelete(ctx context.Context, plugIdentifier string, taskId string) ApiPlugTaskPlugIdentifierTaskIdDeleteRequest {
+	return ApiPlugTaskPlugIdentifierTaskIdDeleteRequest{
+		ApiService:     a,
+		ctx:            ctx,
+		plugIdentifier: plugIdentifier,
+		taskId:         taskId,
+	}
+}
+
+// Execute executes the request
+//
+//	@return TaskResponse
+func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdDeleteExecute(r ApiPlugTaskPlugIdentifierTaskIdDeleteRequest) (*TaskResponse, *http.Response, error) {
+	var (
+		localVarHTTPMethod  = http.MethodDelete
+		localVarPostBody    interface{}
+		formFiles           []formFile
+		localVarReturnValue *TaskResponse
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserSourceApiService.PlugTaskPlugIdentifierTaskIdDelete")
+	if err != nil {
+		return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/plug/task/{plug_identifier}/{task_id}"
+	localVarPath = strings.Replace(localVarPath, "{"+"plug_identifier"+"}", url.PathEscape(parameterToString(r.plugIdentifier, "")), -1)
+	localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterToString(r.taskId, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := url.Values{}
+	localVarFormParams := url.Values{}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"*/*"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
+	if err != nil {
+		return localVarReturnValue, nil, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body)
+	localVarHTTPResponse.Body.Close()
+	localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody))
+	if err != nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: localVarHTTPResponse.Status,
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v map[string]map[string]interface{}
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = err.Error()
+				return localVarReturnValue, localVarHTTPResponse, newErr
+			}
+			newErr.model = v
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: err.Error(),
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	return localVarReturnValue, localVarHTTPResponse, nil
+}
+
+type ApiPlugTaskPlugIdentifierTaskIdGetRequest struct {
+	ctx            context.Context
+	ApiService     *UserSourceApiService
+	plugIdentifier string
+	taskId         string
+}
+
+func (r ApiPlugTaskPlugIdentifierTaskIdGetRequest) Execute() (*TaskResponse, *http.Response, error) {
+	return r.ApiService.PlugTaskPlugIdentifierTaskIdGetExecute(r)
+}
+
+/*
+PlugTaskPlugIdentifierTaskIdGet Gets the status of a plug task
+
+Retrieves the status of a task for the specified plug
+
+	@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	@param plugIdentifier Plug Identifier
+	@param taskId Task ID
+	@return ApiPlugTaskPlugIdentifierTaskIdGetRequest
+*/
+func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdGet(ctx context.Context, plugIdentifier string, taskId string) ApiPlugTaskPlugIdentifierTaskIdGetRequest {
+	return ApiPlugTaskPlugIdentifierTaskIdGetRequest{
+		ApiService:     a,
+		ctx:            ctx,
+		plugIdentifier: plugIdentifier,
+		taskId:         taskId,
+	}
+}
+
+// Execute executes the request
+//
+//	@return TaskResponse
+func (a *UserSourceApiService) PlugTaskPlugIdentifierTaskIdGetExecute(r ApiPlugTaskPlugIdentifierTaskIdGetRequest) (*TaskResponse, *http.Response, error) {
+	var (
+		localVarHTTPMethod  = http.MethodGet
+		localVarPostBody    interface{}
+		formFiles           []formFile
+		localVarReturnValue *TaskResponse
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "UserSourceApiService.PlugTaskPlugIdentifierTaskIdGet")
+	if err != nil {
+		return localVarReturnValue, nil, &GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/plug/task/{plug_identifier}/{task_id}"
+	localVarPath = strings.Replace(localVarPath, "{"+"plug_identifier"+"}", url.PathEscape(parameterToString(r.plugIdentifier, "")), -1)
+	localVarPath = strings.Replace(localVarPath, "{"+"task_id"+"}", url.PathEscape(parameterToString(r.taskId, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := url.Values{}
+	localVarFormParams := url.Values{}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"*/*"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, formFiles)
+	if err != nil {
+		return localVarReturnValue, nil, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	localVarBody, err := ioutil.ReadAll(localVarHTTPResponse.Body)
+	localVarHTTPResponse.Body.Close()
+	localVarHTTPResponse.Body = ioutil.NopCloser(bytes.NewBuffer(localVarBody))
+	if err != nil {
+		return localVarReturnValue, localVarHTTPResponse, err
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: localVarHTTPResponse.Status,
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v map[string]map[string]interface{}
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = err.Error()
+				return localVarReturnValue, localVarHTTPResponse, newErr
+			}
+			newErr.model = v
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := &GenericOpenAPIError{
+			body:  localVarBody,
+			error: err.Error(),
+		}
+		return localVarReturnValue, localVarHTTPResponse, newErr
+	}
+
+	return localVarReturnValue, localVarHTTPResponse, nil
+}
--- a/client.go
+++ b/client.go
@ -3,7 +3,7 @@ Anthrove Orchestrator API

 This service handles the communication between the manager and the plugs

-API version: 0.1-PREVIEW
+API version: 1.0
 Contact: support@anthrove.art
 */

@ -19,6 +19,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"io/ioutil"
 	"log"
 	"mime/multipart"
 	"net/http"
@ -32,16 +33,16 @@ import (
 	"strings"
 	"time"
 	"unicode/utf8"
+
+	"golang.org/x/oauth2"
 )

 var (
-	JsonCheck       = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?json)`)
-	XmlCheck        = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?xml)`)
-	queryParamSplit = regexp.MustCompile(`(^|&)([^&]+)`)
-	queryDescape    = strings.NewReplacer("%5B", "[", "%5D", "]")
+	jsonCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:vnd\.[^;]+\+)?json)`)
+	xmlCheck  = regexp.MustCompile(`(?i:(?:application|text)/xml)`)
 )

-// APIClient manages communication with the Anthrove Orchestrator API API v0.1-PREVIEW
+// APIClient manages communication with the Anthrove Orchestrator API API v1.0
 // In most cases there should be only one, shared, APIClient.
 type APIClient struct {
 	cfg    *Configuration
@ -49,9 +50,11 @@ type APIClient struct {

 	// API Services

-	PlugAPI *PlugAPIService
+	UserApi *UserApiService

-	UserAPI *UserAPIService
+	UserMessageApi *UserMessageApiService
+
+	UserSourceApi *UserSourceApiService
 }

 type service struct {
@ -70,8 +73,9 @@ func NewAPIClient(cfg *Configuration) *APIClient {
 	c.common.client = c

 	// API Services
-	c.PlugAPI = (*PlugAPIService)(&c.common)
-	c.UserAPI = (*UserAPIService)(&c.common)
+	c.UserApi = (*UserApiService)(&c.common)
+	c.UserMessageApi = (*UserMessageApiService)(&c.common)
+	c.UserSourceApi = (*UserSourceApiService)(&c.common)

 	return c
 }
@ -123,112 +127,34 @@ func typeCheckParameter(obj interface{}, expected string, name string) error {

 	// Check the type is as expected.
 	if reflect.TypeOf(obj).String() != expected {
-		return fmt.Errorf("expected %s to be of type %s but received %s", name, expected, reflect.TypeOf(obj).String())
+		return fmt.Errorf("Expected %s to be of type %s but received %s.", name, expected, reflect.TypeOf(obj).String())
 	}
 	return nil
 }

-func parameterValueToString(obj interface{}, key string) string {
-	if reflect.TypeOf(obj).Kind() != reflect.Ptr {
+// parameterToString convert interface{} parameters to string, using a delimiter if format is provided.
+func parameterToString(obj interface{}, collectionFormat string) string {
+	var delimiter string
+
+	switch collectionFormat {
+	case "pipes":
+		delimiter = "|"
+	case "ssv":
+		delimiter = " "
+	case "tsv":
+		delimiter = "\t"
+	case "csv":
+		delimiter = ","
+	}
+
+	if reflect.TypeOf(obj).Kind() == reflect.Slice {
+		return strings.Trim(strings.Replace(fmt.Sprint(obj), " ", delimiter, -1), "[]")
+	} else if t, ok := obj.(time.Time); ok {
+		return t.Format(time.RFC3339)
+	}
+
 	return fmt.Sprintf("%v", obj)
 }
-	var param, ok = obj.(MappedNullable)
-	if !ok {
-		return ""
-	}
-	dataMap, err := param.ToMap()
-	if err != nil {
-		return ""
-	}
-	return fmt.Sprintf("%v", dataMap[key])
-}
-
-// parameterAddToHeaderOrQuery adds the provided object to the request header or url query
-// supporting deep object syntax
-func parameterAddToHeaderOrQuery(headerOrQueryParams interface{}, keyPrefix string, obj interface{}, collectionType string) {
-	var v = reflect.ValueOf(obj)
-	var value = ""
-	if v == reflect.ValueOf(nil) {
-		value = "null"
-	} else {
-		switch v.Kind() {
-		case reflect.Invalid:
-			value = "invalid"
-
-		case reflect.Struct:
-			if t, ok := obj.(MappedNullable); ok {
-				dataMap, err := t.ToMap()
-				if err != nil {
-					return
-				}
-				parameterAddToHeaderOrQuery(headerOrQueryParams, keyPrefix, dataMap, collectionType)
-				return
-			}
-			if t, ok := obj.(time.Time); ok {
-				parameterAddToHeaderOrQuery(headerOrQueryParams, keyPrefix, t.Format(time.RFC3339), collectionType)
-				return
-			}
-			value = v.Type().String() + " value"
-		case reflect.Slice:
-			var indValue = reflect.ValueOf(obj)
-			if indValue == reflect.ValueOf(nil) {
-				return
-			}
-			var lenIndValue = indValue.Len()
-			for i := 0; i < lenIndValue; i++ {
-				var arrayValue = indValue.Index(i)
-				parameterAddToHeaderOrQuery(headerOrQueryParams, keyPrefix, arrayValue.Interface(), collectionType)
-			}
-			return
-
-		case reflect.Map:
-			var indValue = reflect.ValueOf(obj)
-			if indValue == reflect.ValueOf(nil) {
-				return
-			}
-			iter := indValue.MapRange()
-			for iter.Next() {
-				k, v := iter.Key(), iter.Value()
-				parameterAddToHeaderOrQuery(headerOrQueryParams, fmt.Sprintf("%s[%s]", keyPrefix, k.String()), v.Interface(), collectionType)
-			}
-			return
-
-		case reflect.Interface:
-			fallthrough
-		case reflect.Ptr:
-			parameterAddToHeaderOrQuery(headerOrQueryParams, keyPrefix, v.Elem().Interface(), collectionType)
-			return
-
-		case reflect.Int, reflect.Int8, reflect.Int16,
-			reflect.Int32, reflect.Int64:
-			value = strconv.FormatInt(v.Int(), 10)
-		case reflect.Uint, reflect.Uint8, reflect.Uint16,
-			reflect.Uint32, reflect.Uint64, reflect.Uintptr:
-			value = strconv.FormatUint(v.Uint(), 10)
-		case reflect.Float32, reflect.Float64:
-			value = strconv.FormatFloat(v.Float(), 'g', -1, 32)
-		case reflect.Bool:
-			value = strconv.FormatBool(v.Bool())
-		case reflect.String:
-			value = v.String()
-		default:
-			value = v.Type().String() + " value"
-		}
-	}
-
-	switch valuesMap := headerOrQueryParams.(type) {
-	case url.Values:
-		if collectionType == "csv" && valuesMap.Get(keyPrefix) != "" {
-			valuesMap.Set(keyPrefix, valuesMap.Get(keyPrefix)+","+value)
-		} else {
-			valuesMap.Add(keyPrefix, value)
-		}
-		break
-	case map[string]string:
-		valuesMap[keyPrefix] = value
-		break
-	}
-}

 // helper for converting interface{} parameters to json strings
 func parameterToJson(obj interface{}) (string, error) {
@ -379,11 +305,7 @@ func (c *APIClient) prepareRequest(
 	}

 	// Encode the parameters.
-	url.RawQuery = queryParamSplit.ReplaceAllStringFunc(query.Encode(), func(s string) string {
-		pieces := strings.Split(s, "=")
-		pieces[0] = queryDescape.Replace(pieces[0])
-		return strings.Join(pieces, "=")
-	})
+	url.RawQuery = query.Encode()

 	// Generate a new request
 	if body != nil {
@ -413,6 +335,27 @@ func (c *APIClient) prepareRequest(

 		// Walk through any authentication.

+		// OAuth2 authentication
+		if tok, ok := ctx.Value(ContextOAuth2).(oauth2.TokenSource); ok {
+			// We were able to grab an oauth2 token from the context
+			var latestToken *oauth2.Token
+			if latestToken, err = tok.Token(); err != nil {
+				return nil, err
+			}
+
+			latestToken.SetAuthHeader(localVarRequest)
+		}
+
+		// Basic HTTP Authentication
+		if auth, ok := ctx.Value(ContextBasicAuth).(BasicAuth); ok {
+			localVarRequest.SetBasicAuth(auth.UserName, auth.Password)
+		}
+
+		// AccessToken Authentication
+		if auth, ok := ctx.Value(ContextAccessToken).(string); ok {
+			localVarRequest.Header.Add("Authorization", "Bearer "+auth)
+		}
+
 	}

 	for header, value := range c.cfg.DefaultHeader {
@ -429,20 +372,8 @@ func (c *APIClient) decode(v interface{}, b []byte, contentType string) (err err
 		*s = string(b)
 		return nil
 	}
-	if f, ok := v.(*os.File); ok {
-		f, err = os.CreateTemp("", "HttpClientFile")
-		if err != nil {
-			return
-		}
-		_, err = f.Write(b)
-		if err != nil {
-			return
-		}
-		_, err = f.Seek(0, io.SeekStart)
-		return
-	}
 	if f, ok := v.(**os.File); ok {
-		*f, err = os.CreateTemp("", "HttpClientFile")
+		*f, err = ioutil.TempFile("", "HttpClientFile")
 		if err != nil {
 			return
 		}
@ -453,13 +384,13 @@ func (c *APIClient) decode(v interface{}, b []byte, contentType string) (err err
 		_, err = (*f).Seek(0, io.SeekStart)
 		return
 	}
-	if XmlCheck.MatchString(contentType) {
+	if xmlCheck.MatchString(contentType) {
 		if err = xml.Unmarshal(b, v); err != nil {
 			return err
 		}
 		return nil
 	}
-	if JsonCheck.MatchString(contentType) {
+	if jsonCheck.MatchString(contentType) {
 		if actualObj, ok := v.(interface{ GetActualInstance() interface{} }); ok { // oneOf, anyOf schemas
 			if unmarshalObj, ok := actualObj.(interface{ UnmarshalJSON([]byte) error }); ok { // make sure it has UnmarshalJSON defined
 				if err = unmarshalObj.UnmarshalJSON(b); err != nil {
@ -516,22 +447,18 @@ func setBody(body interface{}, contentType string) (bodyBuf *bytes.Buffer, err e

 	if reader, ok := body.(io.Reader); ok {
 		_, err = bodyBuf.ReadFrom(reader)
-	} else if fp, ok := body.(*os.File); ok {
-		_, err = bodyBuf.ReadFrom(fp)
+	} else if fp, ok := body.(**os.File); ok {
+		_, err = bodyBuf.ReadFrom(*fp)
 	} else if b, ok := body.([]byte); ok {
 		_, err = bodyBuf.Write(b)
 	} else if s, ok := body.(string); ok {
 		_, err = bodyBuf.WriteString(s)
 	} else if s, ok := body.(*string); ok {
 		_, err = bodyBuf.WriteString(*s)
-	} else if JsonCheck.MatchString(contentType) {
+	} else if jsonCheck.MatchString(contentType) {
 		err = json.NewEncoder(bodyBuf).Encode(body)
-	} else if XmlCheck.MatchString(contentType) {
-		var bs []byte
-		bs, err = xml.Marshal(body)
-		if err == nil {
-			bodyBuf.Write(bs)
-		}
+	} else if xmlCheck.MatchString(contentType) {
+		err = xml.NewEncoder(bodyBuf).Encode(body)
 	}

 	if err != nil {
@ -539,7 +466,7 @@ func setBody(body interface{}, contentType string) (bodyBuf *bytes.Buffer, err e
 	}

 	if bodyBuf.Len() == 0 {
-		err = fmt.Errorf("invalid body type %s\n", contentType)
+		err = fmt.Errorf("Invalid body type %s\n", contentType)
 		return nil, err
 	}
 	return bodyBuf, nil
@ -641,23 +568,3 @@ func (e GenericOpenAPIError) Body() []byte {
 func (e GenericOpenAPIError) Model() interface{} {
 	return e.model
 }
-
-// format error message using title and detail when model implements rfc7807
-func formatErrorMessage(status string, v interface{}) string {
-	str := ""
-	metaValue := reflect.ValueOf(v).Elem()
-
-	if metaValue.Kind() == reflect.Struct {
-		field := metaValue.FieldByName("Title")
-		if field != (reflect.Value{}) {
-			str = fmt.Sprintf("%s", field.Interface())
-		}
-
-		field = metaValue.FieldByName("Detail")
-		if field != (reflect.Value{}) {
-			str = fmt.Sprintf("%s (%s)", str, field.Interface())
-		}
-	}
-
-	return strings.TrimSpace(fmt.Sprintf("%s %s", status, str))
-}
--- a/configuration.go
+++ b/configuration.go
@ -3,7 +3,7 @@ Anthrove Orchestrator API

 This service handles the communication between the manager and the plugs

-API version: 0.1-PREVIEW
+API version: 1.0
 Contact: support@anthrove.art
 */

@ -29,6 +29,21 @@ func (c contextKey) String() string {
 }

 var (
+	// ContextOAuth2 takes an oauth2.TokenSource as authentication for the request.
+	ContextOAuth2 = contextKey("token")
+
+	// ContextBasicAuth takes BasicAuth as authentication for the request.
+	ContextBasicAuth = contextKey("basic")
+
+	// ContextAccessToken takes a string oauth2 access token as authentication for the request.
+	ContextAccessToken = contextKey("accesstoken")
+
+	// ContextAPIKeys takes a string apikey as authentication for the request
+	ContextAPIKeys = contextKey("apiKeys")
+
+	// ContextHttpSignatureAuth takes HttpSignatureAuth as authentication for the request.
+	ContextHttpSignatureAuth = contextKey("httpsignature")
+
 	// ContextServerIndex uses a server configuration from the index.
 	ContextServerIndex = contextKey("serverIndex")

@ -108,7 +123,7 @@ func (c *Configuration) AddDefaultHeader(key string, value string) {
 // URL formats template on a index using given variables
 func (sc ServerConfigurations) URL(index int, variables map[string]string) (string, error) {
 	if index < 0 || len(sc) <= index {
-		return "", fmt.Errorf("index %v out of range %v", index, len(sc)-1)
+		return "", fmt.Errorf("Index %v out of range %v", index, len(sc)-1)
 	}
 	server := sc[index]
 	url := server.URL
@ -123,7 +138,7 @@ func (sc ServerConfigurations) URL(index int, variables map[string]string) (stri
 				}
 			}
 			if !found {
-				return "", fmt.Errorf("the variable %s in the server URL has invalid value %v. Must be %v", name, value, variable.EnumValues)
+				return "", fmt.Errorf("The variable %s in the server URL has invalid value %v. Must be %v", name, value, variable.EnumValues)
 			}
 			url = strings.Replace(url, "{"+name+"}", value, -1)
 		} else {
--- a/docs/ModelsOrchestratorTask.md
+++ b/docs/ModelsOrchestratorTask.md
@ -1,93 +0,0 @@
-# ModelsOrchestratorTask
-
-## Properties
-
-Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**AnthroveUserId** | **string** |  | 
-**DeepScrape** | **bool** |  | 
-**PlugTask** | [**ModelsPlugTask**](ModelsPlugTask.md) |  | 
-
-## Methods
-
-### NewModelsOrchestratorTask
-
-`func NewModelsOrchestratorTask(anthroveUserId string, deepScrape bool, plugTask ModelsPlugTask, ) *ModelsOrchestratorTask`
-
-NewModelsOrchestratorTask instantiates a new ModelsOrchestratorTask object
-This constructor will assign default values to properties that have it defined,
-and makes sure properties required by API are set, but the set of arguments
-will change when the set of required properties is changed
-
-### NewModelsOrchestratorTaskWithDefaults
-
-`func NewModelsOrchestratorTaskWithDefaults() *ModelsOrchestratorTask`
-
-NewModelsOrchestratorTaskWithDefaults instantiates a new ModelsOrchestratorTask object
-This constructor will only assign default values to properties that have it defined,
-but it doesn't guarantee that properties required by API are set
-
-### GetAnthroveUserId
-
-`func (o *ModelsOrchestratorTask) GetAnthroveUserId() string`
-
-GetAnthroveUserId returns the AnthroveUserId field if non-nil, zero value otherwise.
-
-### GetAnthroveUserIdOk
-
-`func (o *ModelsOrchestratorTask) GetAnthroveUserIdOk() (*string, bool)`
-
-GetAnthroveUserIdOk returns a tuple with the AnthroveUserId field if it's non-nil, zero value otherwise
-and a boolean to check if the value has been set.
-
-### SetAnthroveUserId
-
-`func (o *ModelsOrchestratorTask) SetAnthroveUserId(v string)`
-
-SetAnthroveUserId sets AnthroveUserId field to given value.
-
-
-### GetDeepScrape
-
-`func (o *ModelsOrchestratorTask) GetDeepScrape() bool`
-
-GetDeepScrape returns the DeepScrape field if non-nil, zero value otherwise.
-
-### GetDeepScrapeOk
-
-`func (o *ModelsOrchestratorTask) GetDeepScrapeOk() (*bool, bool)`
-
-GetDeepScrapeOk returns a tuple with the DeepScrape field if it's non-nil, zero value otherwise
-and a boolean to check if the value has been set.
-
-### SetDeepScrape
-
-`func (o *ModelsOrchestratorTask) SetDeepScrape(v bool)`
-
-SetDeepScrape sets DeepScrape field to given value.
-
-
-### GetPlugTask
-
-`func (o *ModelsOrchestratorTask) GetPlugTask() ModelsPlugTask`
-
-GetPlugTask returns the PlugTask field if non-nil, zero value otherwise.
-
-### GetPlugTaskOk
-
-`func (o *ModelsOrchestratorTask) GetPlugTaskOk() (*ModelsPlugTask, bool)`
-
-GetPlugTaskOk returns a tuple with the PlugTask field if it's non-nil, zero value otherwise
-and a boolean to check if the value has been set.
-
-### SetPlugTask
-
-`func (o *ModelsOrchestratorTask) SetPlugTask(v ModelsPlugTask)`
-
-SetPlugTask sets PlugTask field to given value.
-
-
-
-[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
-
-
--- a/docs/ModelsPlugTask.md
+++ b/docs/ModelsPlugTask.md
@ -1,103 +0,0 @@
-# ModelsPlugTask
-
-## Properties
-
-Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**Id** | Pointer to **string** |  | [optional] 
-**TaskState** | Pointer to [**ModelsPlugTaskState**](ModelsPlugTaskState.md) |  | [optional] 
-**UserId** | **string** |  | 
-
-## Methods
-
-### NewModelsPlugTask
-
-`func NewModelsPlugTask(userId string, ) *ModelsPlugTask`
-
-NewModelsPlugTask instantiates a new ModelsPlugTask object
-This constructor will assign default values to properties that have it defined,
-and makes sure properties required by API are set, but the set of arguments
-will change when the set of required properties is changed
-
-### NewModelsPlugTaskWithDefaults
-
-`func NewModelsPlugTaskWithDefaults() *ModelsPlugTask`
-
-NewModelsPlugTaskWithDefaults instantiates a new ModelsPlugTask object
-This constructor will only assign default values to properties that have it defined,
-but it doesn't guarantee that properties required by API are set
-
-### GetId
-
-`func (o *ModelsPlugTask) GetId() string`
-
-GetId returns the Id field if non-nil, zero value otherwise.
-
-### GetIdOk
-
-`func (o *ModelsPlugTask) GetIdOk() (*string, bool)`
-
-GetIdOk returns a tuple with the Id field if it's non-nil, zero value otherwise
-and a boolean to check if the value has been set.
-
-### SetId
-
-`func (o *ModelsPlugTask) SetId(v string)`
-
-SetId sets Id field to given value.
-
-### HasId
-
-`func (o *ModelsPlugTask) HasId() bool`
-
-HasId returns a boolean if a field has been set.
-
-### GetTaskState
-
-`func (o *ModelsPlugTask) GetTaskState() ModelsPlugTaskState`
-
-GetTaskState returns the TaskState field if non-nil, zero value otherwise.
-
-### GetTaskStateOk
-
-`func (o *ModelsPlugTask) GetTaskStateOk() (*ModelsPlugTaskState, bool)`
-
-GetTaskStateOk returns a tuple with the TaskState field if it's non-nil, zero value otherwise
-and a boolean to check if the value has been set.
-
-### SetTaskState
-
-`func (o *ModelsPlugTask) SetTaskState(v ModelsPlugTaskState)`
-
-SetTaskState sets TaskState field to given value.
-
-### HasTaskState
-
-`func (o *ModelsPlugTask) HasTaskState() bool`
-
-HasTaskState returns a boolean if a field has been set.
-
-### GetUserId
-
-`func (o *ModelsPlugTask) GetUserId() string`
-
-GetUserId returns the UserId field if non-nil, zero value otherwise.
-
-### GetUserIdOk
-
-`func (o *ModelsPlugTask) GetUserIdOk() (*string, bool)`
-
-GetUserIdOk returns a tuple with the UserId field if it's non-nil, zero value otherwise
-and a boolean to check if the value has been set.
-
-### SetUserId
-
-`func (o *ModelsPlugTask) SetUserId(v string)`
-
-SetUserId sets UserId field to given value.
-
-
-
-[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
-
-
--- a/docs/ModelsPlugTaskState.md
+++ b/docs/ModelsPlugTaskState.md
@ -1,17 +0,0 @@
-# ModelsPlugTaskState
-
-## Enum
-
-
-* `PlugTaskStateUnknown` (value: `"UNKNOWN"`)
-
-* `PlugTaskStateStarted` (value: `"STARTED"`)
-
-* `PlugTaskStateRunning` (value: `"RUNNING"`)
-
-* `PlugTaskStateStopped` (value: `"STOPPED"`)
-
-
-[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
-
-
--- a/docs/PlugAPI.md
+++ b/docs/PlugAPI.md
@ -1,223 +0,0 @@
-# \PlugAPI
-
-All URIs are relative to */api/v1*
-
-Method | HTTP request | Description
------------- | ------------- | -------------
-[**PlugPlugTypePut**](PlugAPI.md#PlugPlugTypePut) | **Put** /plug/{plug_type} | Initiates a scraping operation for a user with a specific plug type
-[**PlugPlugTypeTaskIdDelete**](PlugAPI.md#PlugPlugTypeTaskIdDelete) | **Delete** /plug/{plug_type}/{task_id} | Stops a scraping operation for a user with a specific plug type
-[**PlugPlugTypeTaskIdGet**](PlugAPI.md#PlugPlugTypeTaskIdGet) | **Get** /plug/{plug_type}/{task_id} | Retrieves the status of a specific task type
-
-
-
-## PlugPlugTypePut
-
-> PlugPlugTypePut(ctx, plugType).Request(request).Execute()
-
-Initiates a scraping operation for a user with a specific plug type
-
-
-
-### Example
-
-```go
-package main
-
-import (
-	"context"
-	"fmt"
-	"os"
-	openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client"
-)
-
-func main() {
-	plugType := "plugType_example" // string | supported plug type
-	request := *openapiclient.NewModelsOrchestratorTask("AnthroveUserId_example", false, *openapiclient.NewModelsPlugTask("UserId_example")) // ModelsOrchestratorTask | aa
-
-	configuration := openapiclient.NewConfiguration()
-	apiClient := openapiclient.NewAPIClient(configuration)
-	r, err := apiClient.PlugAPI.PlugPlugTypePut(context.Background(), plugType).Request(request).Execute()
-	if err != nil {
-		fmt.Fprintf(os.Stderr, "Error when calling `PlugAPI.PlugPlugTypePut``: %v\n", err)
-		fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
-	}
-}
-```
-
-### Path Parameters
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
-**plugType** | **string** | supported plug type | 
-
-### Other Parameters
-
-Other parameters are passed through a pointer to a apiPlugPlugTypePutRequest struct via the builder pattern
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-
- **request** | [**ModelsOrchestratorTask**](ModelsOrchestratorTask.md) | aa | 
-
-### Return type
-
- (empty response body)
-
-### Authorization
-
-No authorization required
-
-### HTTP request headers
-
- **Content-Type**: application/json
- **Accept**: Not defined
-
-[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
-[[Back to Model list]](../README.md#documentation-for-models)
-[[Back to README]](../README.md)
-
-
-## PlugPlugTypeTaskIdDelete
-
-> PlugPlugTypeTaskIdDelete(ctx, plugType, taskId).Execute()
-
-Stops a scraping operation for a user with a specific plug type
-
-
-
-### Example
-
-```go
-package main
-
-import (
-	"context"
-	"fmt"
-	"os"
-	openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client"
-)
-
-func main() {
-	plugType := "plugType_example" // string | supported plug type
-	taskId := "taskId_example" // string | id of task
-
-	configuration := openapiclient.NewConfiguration()
-	apiClient := openapiclient.NewAPIClient(configuration)
-	r, err := apiClient.PlugAPI.PlugPlugTypeTaskIdDelete(context.Background(), plugType, taskId).Execute()
-	if err != nil {
-		fmt.Fprintf(os.Stderr, "Error when calling `PlugAPI.PlugPlugTypeTaskIdDelete``: %v\n", err)
-		fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
-	}
-}
-```
-
-### Path Parameters
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
-**plugType** | **string** | supported plug type | 
-**taskId** | **string** | id of task | 
-
-### Other Parameters
-
-Other parameters are passed through a pointer to a apiPlugPlugTypeTaskIdDeleteRequest struct via the builder pattern
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-
-
-
-### Return type
-
- (empty response body)
-
-### Authorization
-
-No authorization required
-
-### HTTP request headers
-
- **Content-Type**: Not defined
- **Accept**: Not defined
-
-[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
-[[Back to Model list]](../README.md#documentation-for-models)
-[[Back to README]](../README.md)
-
-
-## PlugPlugTypeTaskIdGet
-
-> PlugPlugTypeTaskIdGet(ctx, plugType, taskId).Execute()
-
-Retrieves the status of a specific task type
-
-
-
-### Example
-
-```go
-package main
-
-import (
-	"context"
-	"fmt"
-	"os"
-	openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client"
-)
-
-func main() {
-	plugType := "plugType_example" // string | supported plug type
-	taskId := "taskId_example" // string | id of task
-
-	configuration := openapiclient.NewConfiguration()
-	apiClient := openapiclient.NewAPIClient(configuration)
-	r, err := apiClient.PlugAPI.PlugPlugTypeTaskIdGet(context.Background(), plugType, taskId).Execute()
-	if err != nil {
-		fmt.Fprintf(os.Stderr, "Error when calling `PlugAPI.PlugPlugTypeTaskIdGet``: %v\n", err)
-		fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
-	}
-}
-```
-
-### Path Parameters
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
-**plugType** | **string** | supported plug type | 
-**taskId** | **string** | id of task | 
-
-### Other Parameters
-
-Other parameters are passed through a pointer to a apiPlugPlugTypeTaskIdGetRequest struct via the builder pattern
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-
-
-
-### Return type
-
- (empty response body)
-
-### Authorization
-
-No authorization required
-
-### HTTP request headers
-
- **Content-Type**: Not defined
- **Accept**: Not defined
-
-[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
-[[Back to Model list]](../README.md#documentation-for-models)
-[[Back to README]](../README.md)
-
--- a/docs/TaskMessage.md
+++ b/docs/TaskMessage.md
@ -0,0 +1,134 @@
+# TaskMessage
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**Body** | Pointer to **string** |  | [optional] 
+**CreatedAt** | Pointer to **string** |  | [optional] 
+**Title** | Pointer to **string** |  | [optional] 
+**UserSourceId** | Pointer to **string** |  | [optional] 
+
+## Methods
+
+### NewTaskMessage
+
+`func NewTaskMessage() *TaskMessage`
+
+NewTaskMessage instantiates a new TaskMessage object
+This constructor will assign default values to properties that have it defined,
+and makes sure properties required by API are set, but the set of arguments
+will change when the set of required properties is changed
+
+### NewTaskMessageWithDefaults
+
+`func NewTaskMessageWithDefaults() *TaskMessage`
+
+NewTaskMessageWithDefaults instantiates a new TaskMessage object
+This constructor will only assign default values to properties that have it defined,
+but it doesn't guarantee that properties required by API are set
+
+### GetBody
+
+`func (o *TaskMessage) GetBody() string`
+
+GetBody returns the Body field if non-nil, zero value otherwise.
+
+### GetBodyOk
+
+`func (o *TaskMessage) GetBodyOk() (*string, bool)`
+
+GetBodyOk returns a tuple with the Body field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetBody
+
+`func (o *TaskMessage) SetBody(v string)`
+
+SetBody sets Body field to given value.
+
+### HasBody
+
+`func (o *TaskMessage) HasBody() bool`
+
+HasBody returns a boolean if a field has been set.
+
+### GetCreatedAt
+
+`func (o *TaskMessage) GetCreatedAt() string`
+
+GetCreatedAt returns the CreatedAt field if non-nil, zero value otherwise.
+
+### GetCreatedAtOk
+
+`func (o *TaskMessage) GetCreatedAtOk() (*string, bool)`
+
+GetCreatedAtOk returns a tuple with the CreatedAt field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetCreatedAt
+
+`func (o *TaskMessage) SetCreatedAt(v string)`
+
+SetCreatedAt sets CreatedAt field to given value.
+
+### HasCreatedAt
+
+`func (o *TaskMessage) HasCreatedAt() bool`
+
+HasCreatedAt returns a boolean if a field has been set.
+
+### GetTitle
+
+`func (o *TaskMessage) GetTitle() string`
+
+GetTitle returns the Title field if non-nil, zero value otherwise.
+
+### GetTitleOk
+
+`func (o *TaskMessage) GetTitleOk() (*string, bool)`
+
+GetTitleOk returns a tuple with the Title field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetTitle
+
+`func (o *TaskMessage) SetTitle(v string)`
+
+SetTitle sets Title field to given value.
+
+### HasTitle
+
+`func (o *TaskMessage) HasTitle() bool`
+
+HasTitle returns a boolean if a field has been set.
+
+### GetUserSourceId
+
+`func (o *TaskMessage) GetUserSourceId() string`
+
+GetUserSourceId returns the UserSourceId field if non-nil, zero value otherwise.
+
+### GetUserSourceIdOk
+
+`func (o *TaskMessage) GetUserSourceIdOk() (*string, bool)`
+
+GetUserSourceIdOk returns a tuple with the UserSourceId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetUserSourceId
+
+`func (o *TaskMessage) SetUserSourceId(v string)`
+
+SetUserSourceId sets UserSourceId field to given value.
+
+### HasUserSourceId
+
+`func (o *TaskMessage) HasUserSourceId() bool`
+
+HasUserSourceId returns a boolean if a field has been set.
+
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+
--- a/docs/TaskResponse.md
+++ b/docs/TaskResponse.md
@ -0,0 +1,82 @@
+# TaskResponse
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**PlugTaskId** | Pointer to **string** |  | [optional] 
+**PlugTaskStatus** | Pointer to **string** |  | [optional] 
+
+## Methods
+
+### NewTaskResponse
+
+`func NewTaskResponse() *TaskResponse`
+
+NewTaskResponse instantiates a new TaskResponse object
+This constructor will assign default values to properties that have it defined,
+and makes sure properties required by API are set, but the set of arguments
+will change when the set of required properties is changed
+
+### NewTaskResponseWithDefaults
+
+`func NewTaskResponseWithDefaults() *TaskResponse`
+
+NewTaskResponseWithDefaults instantiates a new TaskResponse object
+This constructor will only assign default values to properties that have it defined,
+but it doesn't guarantee that properties required by API are set
+
+### GetPlugTaskId
+
+`func (o *TaskResponse) GetPlugTaskId() string`
+
+GetPlugTaskId returns the PlugTaskId field if non-nil, zero value otherwise.
+
+### GetPlugTaskIdOk
+
+`func (o *TaskResponse) GetPlugTaskIdOk() (*string, bool)`
+
+GetPlugTaskIdOk returns a tuple with the PlugTaskId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetPlugTaskId
+
+`func (o *TaskResponse) SetPlugTaskId(v string)`
+
+SetPlugTaskId sets PlugTaskId field to given value.
+
+### HasPlugTaskId
+
+`func (o *TaskResponse) HasPlugTaskId() bool`
+
+HasPlugTaskId returns a boolean if a field has been set.
+
+### GetPlugTaskStatus
+
+`func (o *TaskResponse) GetPlugTaskStatus() string`
+
+GetPlugTaskStatus returns the PlugTaskStatus field if non-nil, zero value otherwise.
+
+### GetPlugTaskStatusOk
+
+`func (o *TaskResponse) GetPlugTaskStatusOk() (*string, bool)`
+
+GetPlugTaskStatusOk returns a tuple with the PlugTaskStatus field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetPlugTaskStatus
+
+`func (o *TaskResponse) SetPlugTaskStatus(v string)`
+
+SetPlugTaskStatus sets PlugTaskStatus field to given value.
+
+### HasPlugTaskStatus
+
+`func (o *TaskResponse) HasPlugTaskStatus() bool`
+
+HasPlugTaskStatus returns a boolean if a field has been set.
+
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+
--- a/docs/TaskStartTask.md
+++ b/docs/TaskStartTask.md
@ -0,0 +1,108 @@
+# TaskStartTask
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**UserApiKey** | Pointer to **string** |  | [optional] 
+**UserId** | Pointer to **string** |  | [optional] 
+**UserSourceId** | Pointer to **string** |  | [optional] 
+
+## Methods
+
+### NewTaskStartTask
+
+`func NewTaskStartTask() *TaskStartTask`
+
+NewTaskStartTask instantiates a new TaskStartTask object
+This constructor will assign default values to properties that have it defined,
+and makes sure properties required by API are set, but the set of arguments
+will change when the set of required properties is changed
+
+### NewTaskStartTaskWithDefaults
+
+`func NewTaskStartTaskWithDefaults() *TaskStartTask`
+
+NewTaskStartTaskWithDefaults instantiates a new TaskStartTask object
+This constructor will only assign default values to properties that have it defined,
+but it doesn't guarantee that properties required by API are set
+
+### GetUserApiKey
+
+`func (o *TaskStartTask) GetUserApiKey() string`
+
+GetUserApiKey returns the UserApiKey field if non-nil, zero value otherwise.
+
+### GetUserApiKeyOk
+
+`func (o *TaskStartTask) GetUserApiKeyOk() (*string, bool)`
+
+GetUserApiKeyOk returns a tuple with the UserApiKey field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetUserApiKey
+
+`func (o *TaskStartTask) SetUserApiKey(v string)`
+
+SetUserApiKey sets UserApiKey field to given value.
+
+### HasUserApiKey
+
+`func (o *TaskStartTask) HasUserApiKey() bool`
+
+HasUserApiKey returns a boolean if a field has been set.
+
+### GetUserId
+
+`func (o *TaskStartTask) GetUserId() string`
+
+GetUserId returns the UserId field if non-nil, zero value otherwise.
+
+### GetUserIdOk
+
+`func (o *TaskStartTask) GetUserIdOk() (*string, bool)`
+
+GetUserIdOk returns a tuple with the UserId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetUserId
+
+`func (o *TaskStartTask) SetUserId(v string)`
+
+SetUserId sets UserId field to given value.
+
+### HasUserId
+
+`func (o *TaskStartTask) HasUserId() bool`
+
+HasUserId returns a boolean if a field has been set.
+
+### GetUserSourceId
+
+`func (o *TaskStartTask) GetUserSourceId() string`
+
+GetUserSourceId returns the UserSourceId field if non-nil, zero value otherwise.
+
+### GetUserSourceIdOk
+
+`func (o *TaskStartTask) GetUserSourceIdOk() (*string, bool)`
+
+GetUserSourceIdOk returns a tuple with the UserSourceId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetUserSourceId
+
+`func (o *TaskStartTask) SetUserSourceId(v string)`
+
+SetUserSourceId sets UserSourceId field to given value.
+
+### HasUserSourceId
+
+`func (o *TaskStartTask) HasUserSourceId() bool`
+
+HasUserSourceId returns a boolean if a field has been set.
+
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+
--- a/docs/UserAPI.md
+++ b/docs/UserAPI.md
@ -1,77 +0,0 @@
-# \UserAPI
-
-All URIs are relative to */api/v1*
-
-Method | HTTP request | Description
------------- | ------------- | -------------
-[**UserUserIdPut**](UserAPI.md#UserUserIdPut) | **Put** /user/{user_id} | Initiates a scraping operation for the entire user
-
-
-
-## UserUserIdPut
-
-> UserUserIdPut(ctx, userId).Execute()
-
-Initiates a scraping operation for the entire user
-
-
-
-### Example
-
-```go
-package main
-
-import (
-	"context"
-	"fmt"
-	"os"
-	openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client"
-)
-
-func main() {
-	userId := "userId_example" // string | Anthrove UserID
-
-	configuration := openapiclient.NewConfiguration()
-	apiClient := openapiclient.NewAPIClient(configuration)
-	r, err := apiClient.UserAPI.UserUserIdPut(context.Background(), userId).Execute()
-	if err != nil {
-		fmt.Fprintf(os.Stderr, "Error when calling `UserAPI.UserUserIdPut``: %v\n", err)
-		fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
-	}
-}
-```
-
-### Path Parameters
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
-**userId** | **string** | Anthrove UserID | 
-
-### Other Parameters
-
-Other parameters are passed through a pointer to a apiUserUserIdPutRequest struct via the builder pattern
-
-
-Name | Type | Description  | Notes
------------- | ------------- | ------------- | -------------
-
-
-### Return type
-
- (empty response body)
-
-### Authorization
-
-No authorization required
-
-### HTTP request headers
-
- **Content-Type**: Not defined
- **Accept**: Not defined
-
-[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
-[[Back to Model list]](../README.md#documentation-for-models)
-[[Back to README]](../README.md)
-
--- a/docs/UserApi.md
+++ b/docs/UserApi.md
@ -0,0 +1,141 @@
+# \UserApi
+
+All URIs are relative to */api/v1*
+
+Method | HTTP request | Description
+------------- | ------------- | -------------
+[**UserTaskPost**](UserApi.md#UserTaskPost) | **Post** /user/task | Start scraping all user sources
+[**UserTaskUserIdGet**](UserApi.md#UserTaskUserIdGet) | **Get** /user/task/{user_id} | Gets all tasks of a user
+
+
+
+## UserTaskPost
+
+> [][]TaskResponse UserTaskPost(ctx).Execute()
+
+Start scraping all user sources
+
+
+
+### Example
+
+```go
+package main
+
+import (
+    "context"
+    "fmt"
+    "os"
+    openapiclient "./openapi"
+)
+
+func main() {
+
+    configuration := openapiclient.NewConfiguration()
+    apiClient := openapiclient.NewAPIClient(configuration)
+    resp, r, err := apiClient.UserApi.UserTaskPost(context.Background()).Execute()
+    if err != nil {
+        fmt.Fprintf(os.Stderr, "Error when calling `UserApi.UserTaskPost``: %v\n", err)
+        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
+    }
+    // response from `UserTaskPost`: [][]TaskResponse
+    fmt.Fprintf(os.Stdout, "Response from `UserApi.UserTaskPost`: %v\n", resp)
+}
+```
+
+### Path Parameters
+
+This endpoint does not need any parameter.
+
+### Other Parameters
+
+Other parameters are passed through a pointer to a apiUserTaskPostRequest struct via the builder pattern
+
+
+### Return type
+
+[**[][]TaskResponse**](array.md)
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+- **Content-Type**: Not defined
+- **Accept**: */*
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
+[[Back to Model list]](../README.md#documentation-for-models)
+[[Back to README]](../README.md)
+
+
+## UserTaskUserIdGet
+
+> []TaskResponse UserTaskUserIdGet(ctx, userId).Execute()
+
+Gets all tasks of a user
+
+
+
+### Example
+
+```go
+package main
+
+import (
+    "context"
+    "fmt"
+    "os"
+    openapiclient "./openapi"
+)
+
+func main() {
+    userId := "userId_example" // string | User ID
+
+    configuration := openapiclient.NewConfiguration()
+    apiClient := openapiclient.NewAPIClient(configuration)
+    resp, r, err := apiClient.UserApi.UserTaskUserIdGet(context.Background(), userId).Execute()
+    if err != nil {
+        fmt.Fprintf(os.Stderr, "Error when calling `UserApi.UserTaskUserIdGet``: %v\n", err)
+        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
+    }
+    // response from `UserTaskUserIdGet`: []TaskResponse
+    fmt.Fprintf(os.Stdout, "Response from `UserApi.UserTaskUserIdGet`: %v\n", resp)
+}
+```
+
+### Path Parameters
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
+**userId** | **string** | User ID | 
+
+### Other Parameters
+
+Other parameters are passed through a pointer to a apiUserTaskUserIdGetRequest struct via the builder pattern
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+
+
+### Return type
+
+[**[]TaskResponse**](TaskResponse.md)
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+- **Content-Type**: Not defined
+- **Accept**: */*
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
+[[Back to Model list]](../README.md#documentation-for-models)
+[[Back to README]](../README.md)
+
--- a/docs/UserMessageApi.md
+++ b/docs/UserMessageApi.md
@ -0,0 +1,82 @@
+# \UserMessageApi
+
+All URIs are relative to */api/v1*
+
+Method | HTTP request | Description
+------------- | ------------- | -------------
+[**PlugMessagesPlugIdentifierUserSourceIdGet**](UserMessageApi.md#PlugMessagesPlugIdentifierUserSourceIdGet) | **Get** /plug/messages/{plug_identifier}/{user_source_id} | Get all Messages from a user
+
+
+
+## PlugMessagesPlugIdentifierUserSourceIdGet
+
+> []TaskMessage PlugMessagesPlugIdentifierUserSourceIdGet(ctx, userSourceId, plugIdentifier).Execute()
+
+Get all Messages from a user
+
+
+
+### Example
+
+```go
+package main
+
+import (
+    "context"
+    "fmt"
+    "os"
+    openapiclient "./openapi"
+)
+
+func main() {
+    userSourceId := "userSourceId_example" // string | User Source ID
+    plugIdentifier := "plugIdentifier_example" // string | Plug Identifier
+
+    configuration := openapiclient.NewConfiguration()
+    apiClient := openapiclient.NewAPIClient(configuration)
+    resp, r, err := apiClient.UserMessageApi.PlugMessagesPlugIdentifierUserSourceIdGet(context.Background(), userSourceId, plugIdentifier).Execute()
+    if err != nil {
+        fmt.Fprintf(os.Stderr, "Error when calling `UserMessageApi.PlugMessagesPlugIdentifierUserSourceIdGet``: %v\n", err)
+        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
+    }
+    // response from `PlugMessagesPlugIdentifierUserSourceIdGet`: []TaskMessage
+    fmt.Fprintf(os.Stdout, "Response from `UserMessageApi.PlugMessagesPlugIdentifierUserSourceIdGet`: %v\n", resp)
+}
+```
+
+### Path Parameters
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
+**userSourceId** | **string** | User Source ID | 
+**plugIdentifier** | **string** | Plug Identifier | 
+
+### Other Parameters
+
+Other parameters are passed through a pointer to a apiPlugMessagesPlugIdentifierUserSourceIdGetRequest struct via the builder pattern
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+
+
+
+### Return type
+
+[**[]TaskMessage**](TaskMessage.md)
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+- **Content-Type**: Not defined
+- **Accept**: */*
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
+[[Back to Model list]](../README.md#documentation-for-models)
+[[Back to README]](../README.md)
+
--- a/docs/UserSourceApi.md
+++ b/docs/UserSourceApi.md
@ -0,0 +1,229 @@
+# \UserSourceApi
+
+All URIs are relative to */api/v1*
+
+Method | HTTP request | Description
+------------- | ------------- | -------------
+[**PlugTaskPlugIdentifierPost**](UserSourceApi.md#PlugTaskPlugIdentifierPost) | **Post** /plug/task/{plug_identifier} | Start a plug task
+[**PlugTaskPlugIdentifierTaskIdDelete**](UserSourceApi.md#PlugTaskPlugIdentifierTaskIdDelete) | **Delete** /plug/task/{plug_identifier}/{task_id} | Stop a plug task
+[**PlugTaskPlugIdentifierTaskIdGet**](UserSourceApi.md#PlugTaskPlugIdentifierTaskIdGet) | **Get** /plug/task/{plug_identifier}/{task_id} | Gets the status of a plug task
+
+
+
+## PlugTaskPlugIdentifierPost
+
+> TaskResponse PlugTaskPlugIdentifierPost(ctx, plugIdentifier).Task(task).Execute()
+
+Start a plug task
+
+
+
+### Example
+
+```go
+package main
+
+import (
+    "context"
+    "fmt"
+    "os"
+    openapiclient "./openapi"
+)
+
+func main() {
+    plugIdentifier := "plugIdentifier_example" // string | Plug Identifier
+    task := *openapiclient.NewTaskStartTask() // TaskStartTask | Task Details
+
+    configuration := openapiclient.NewConfiguration()
+    apiClient := openapiclient.NewAPIClient(configuration)
+    resp, r, err := apiClient.UserSourceApi.PlugTaskPlugIdentifierPost(context.Background(), plugIdentifier).Task(task).Execute()
+    if err != nil {
+        fmt.Fprintf(os.Stderr, "Error when calling `UserSourceApi.PlugTaskPlugIdentifierPost``: %v\n", err)
+        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
+    }
+    // response from `PlugTaskPlugIdentifierPost`: TaskResponse
+    fmt.Fprintf(os.Stdout, "Response from `UserSourceApi.PlugTaskPlugIdentifierPost`: %v\n", resp)
+}
+```
+
+### Path Parameters
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
+**plugIdentifier** | **string** | Plug Identifier | 
+
+### Other Parameters
+
+Other parameters are passed through a pointer to a apiPlugTaskPlugIdentifierPostRequest struct via the builder pattern
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+
+ **task** | [**TaskStartTask**](TaskStartTask.md) | Task Details | 
+
+### Return type
+
+[**TaskResponse**](TaskResponse.md)
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+- **Content-Type**: Not defined
+- **Accept**: */*
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
+[[Back to Model list]](../README.md#documentation-for-models)
+[[Back to README]](../README.md)
+
+
+## PlugTaskPlugIdentifierTaskIdDelete
+
+> TaskResponse PlugTaskPlugIdentifierTaskIdDelete(ctx, plugIdentifier, taskId).Execute()
+
+Stop a plug task
+
+
+
+### Example
+
+```go
+package main
+
+import (
+    "context"
+    "fmt"
+    "os"
+    openapiclient "./openapi"
+)
+
+func main() {
+    plugIdentifier := "plugIdentifier_example" // string | Plug Identifier
+    taskId := "taskId_example" // string | Task ID
+
+    configuration := openapiclient.NewConfiguration()
+    apiClient := openapiclient.NewAPIClient(configuration)
+    resp, r, err := apiClient.UserSourceApi.PlugTaskPlugIdentifierTaskIdDelete(context.Background(), plugIdentifier, taskId).Execute()
+    if err != nil {
+        fmt.Fprintf(os.Stderr, "Error when calling `UserSourceApi.PlugTaskPlugIdentifierTaskIdDelete``: %v\n", err)
+        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
+    }
+    // response from `PlugTaskPlugIdentifierTaskIdDelete`: TaskResponse
+    fmt.Fprintf(os.Stdout, "Response from `UserSourceApi.PlugTaskPlugIdentifierTaskIdDelete`: %v\n", resp)
+}
+```
+
+### Path Parameters
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
+**plugIdentifier** | **string** | Plug Identifier | 
+**taskId** | **string** | Task ID | 
+
+### Other Parameters
+
+Other parameters are passed through a pointer to a apiPlugTaskPlugIdentifierTaskIdDeleteRequest struct via the builder pattern
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+
+
+
+### Return type
+
+[**TaskResponse**](TaskResponse.md)
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+- **Content-Type**: Not defined
+- **Accept**: */*
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
+[[Back to Model list]](../README.md#documentation-for-models)
+[[Back to README]](../README.md)
+
+
+## PlugTaskPlugIdentifierTaskIdGet
+
+> TaskResponse PlugTaskPlugIdentifierTaskIdGet(ctx, plugIdentifier, taskId).Execute()
+
+Gets the status of a plug task
+
+
+
+### Example
+
+```go
+package main
+
+import (
+    "context"
+    "fmt"
+    "os"
+    openapiclient "./openapi"
+)
+
+func main() {
+    plugIdentifier := "plugIdentifier_example" // string | Plug Identifier
+    taskId := "taskId_example" // string | Task ID
+
+    configuration := openapiclient.NewConfiguration()
+    apiClient := openapiclient.NewAPIClient(configuration)
+    resp, r, err := apiClient.UserSourceApi.PlugTaskPlugIdentifierTaskIdGet(context.Background(), plugIdentifier, taskId).Execute()
+    if err != nil {
+        fmt.Fprintf(os.Stderr, "Error when calling `UserSourceApi.PlugTaskPlugIdentifierTaskIdGet``: %v\n", err)
+        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
+    }
+    // response from `PlugTaskPlugIdentifierTaskIdGet`: TaskResponse
+    fmt.Fprintf(os.Stdout, "Response from `UserSourceApi.PlugTaskPlugIdentifierTaskIdGet`: %v\n", resp)
+}
+```
+
+### Path Parameters
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+**ctx** | **context.Context** | context for authentication, logging, cancellation, deadlines, tracing, etc.
+**plugIdentifier** | **string** | Plug Identifier | 
+**taskId** | **string** | Task ID | 
+
+### Other Parameters
+
+Other parameters are passed through a pointer to a apiPlugTaskPlugIdentifierTaskIdGetRequest struct via the builder pattern
+
+
+Name | Type | Description  | Notes
+------------- | ------------- | ------------- | -------------
+
+
+
+### Return type
+
+[**TaskResponse**](TaskResponse.md)
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+- **Content-Type**: Not defined
+- **Accept**: */*
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints)
+[[Back to Model list]](../README.md#documentation-for-models)
+[[Back to README]](../README.md)
+
--- a/go.mod
+++ b/go.mod
@ -1,11 +1,5 @@
 module git.anthrove.art/Anthrove/orchestrator-swagger-go-client

-go 1.18
+go 1.13

-require github.com/stretchr/testify v1.9.0
-
-require (
-	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/pmezard/go-difflib v1.0.0 // indirect
-	gopkg.in/yaml.v3 v3.0.1 // indirect
-)
+require golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558
--- a/go.sum
+++ b/go.sum
@ -1,10 +1,362 @@
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
+cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
+cloud.google.com/go v0.38.0/go.mod h1:990N+gfupTy94rShfmMCWGDn0LpTmnzTp2qbd1dvSRU=
+cloud.google.com/go v0.44.1/go.mod h1:iSa0KzasP4Uvy3f1mN/7PiObzGgflwredwwASm/v6AU=
+cloud.google.com/go v0.44.2/go.mod h1:60680Gw3Yr4ikxnPRS/oxxkBccT6SA1yMk63TGekxKY=
+cloud.google.com/go v0.45.1/go.mod h1:RpBamKRgapWJb87xiFSdk4g1CME7QZg3uwTez+TSTjc=
+cloud.google.com/go v0.46.3/go.mod h1:a6bKKbmY7er1mI7TEI4lsAkts/mkhTSZK8w33B4RAg0=
+cloud.google.com/go v0.50.0/go.mod h1:r9sluTvynVuxRIOHXQEHMFffphuXHOMZMycpNR5e6To=
+cloud.google.com/go v0.52.0/go.mod h1:pXajvRH/6o3+F9jDHZWQ5PbGhn+o8w9qiu/CffaVdO4=
+cloud.google.com/go v0.53.0/go.mod h1:fp/UouUEsRkN6ryDKNW/Upv/JBKnv6WDthjR6+vze6M=
+cloud.google.com/go v0.54.0/go.mod h1:1rq2OEkV3YMf6n/9ZvGWI3GWw0VoqH/1x2nd8Is/bPc=
+cloud.google.com/go v0.56.0/go.mod h1:jr7tqZxxKOVYizybht9+26Z/gUq7tiRzu+ACVAMbKVk=
+cloud.google.com/go v0.57.0/go.mod h1:oXiQ6Rzq3RAkkY7N6t3TcE6jE+CIBBbA36lwQ1JyzZs=
+cloud.google.com/go v0.62.0/go.mod h1:jmCYTdRCQuc1PHIIJ/maLInMho30T/Y0M4hTdTShOYc=
+cloud.google.com/go v0.65.0/go.mod h1:O5N8zS7uWy9vkA9vayVHs65eM1ubvY4h553ofrNHObY=
+cloud.google.com/go/bigquery v1.0.1/go.mod h1:i/xbL2UlR5RvWAURpBYZTtm/cXjCha9lbfbpx4poX+o=
+cloud.google.com/go/bigquery v1.3.0/go.mod h1:PjpwJnslEMmckchkHFfq+HTD2DmtT67aNFKH1/VBDHE=
+cloud.google.com/go/bigquery v1.4.0/go.mod h1:S8dzgnTigyfTmLBfrtrhyYhwRxG72rYxvftPBK2Dvzc=
+cloud.google.com/go/bigquery v1.5.0/go.mod h1:snEHRnqQbz117VIFhE8bmtwIDY80NLUZUMb4Nv6dBIg=
+cloud.google.com/go/bigquery v1.7.0/go.mod h1://okPTzCYNXSlb24MZs83e2Do+h+VXtc4gLoIoXIAPc=
+cloud.google.com/go/bigquery v1.8.0/go.mod h1:J5hqkt3O0uAFnINi6JXValWIb1v0goeZM77hZzJN/fQ=
+cloud.google.com/go/datastore v1.0.0/go.mod h1:LXYbyblFSglQ5pkeyhO+Qmw7ukd3C+pD7TKLgZqpHYE=
+cloud.google.com/go/datastore v1.1.0/go.mod h1:umbIZjpQpHh4hmRpGhH4tLFup+FVzqBi1b3c64qFpCk=
+cloud.google.com/go/pubsub v1.0.1/go.mod h1:R0Gpsv3s54REJCy4fxDixWD93lHJMoZTyQ2kNxGRt3I=
+cloud.google.com/go/pubsub v1.1.0/go.mod h1:EwwdRX2sKPjnvnqCa270oGRyludottCI76h+R3AArQw=
+cloud.google.com/go/pubsub v1.2.0/go.mod h1:jhfEVHT8odbXTkndysNHCcx0awwzvfOlguIAii9o8iA=
+cloud.google.com/go/pubsub v1.3.1/go.mod h1:i+ucay31+CNRpDW4Lu78I4xXG+O1r/MAHgjpRVR+TSU=
+cloud.google.com/go/storage v1.0.0/go.mod h1:IhtSnM/ZTZV8YYJWCY8RULGVqBDmpoyjwiyrjsg+URw=
+cloud.google.com/go/storage v1.5.0/go.mod h1:tpKbwo567HUNpVclU5sGELwQWBDZ8gh0ZeosJ0Rtdos=
+cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohlUTyfDhBk=
+cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs=
+cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0=
+dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
+github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
+github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
+github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
+github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
+github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
+github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
+github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
+github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
+github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
+github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98=
+github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
+github.com/go-gl/glfw v0.0.0-20190409004039-e6da0acd62b1/go.mod h1:vR7hzQXu2zJy9AVAgeJqvqgH9Q5CA+iKCZ2gyEVpxRU=
+github.com/go-gl/glfw/v3.3/glfw v0.0.0-20191125211704-12ad95a8df72/go.mod h1:tQ2UAYgL5IevRw8kRxooKSPJfGvJ9fJQFa0TUsXzTg8=
+github.com/go-gl/glfw/v3.3/glfw v0.0.0-20200222043503-6f7a984d4dc4/go.mod h1:tQ2UAYgL5IevRw8kRxooKSPJfGvJ9fJQFa0TUsXzTg8=
+github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
+github.com/golang/groupcache v0.0.0-20190702054246-869f871628b6/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
+github.com/golang/groupcache v0.0.0-20191227052852-215e87163ea7/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
+github.com/golang/groupcache v0.0.0-20200121045136-8c9f03a8e57e/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
+github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
+github.com/golang/mock v1.2.0/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
+github.com/golang/mock v1.3.1/go.mod h1:sBzyDLLjw3U8JLTeZvSv8jJB+tU5PVekmnlKIyFUx0Y=
+github.com/golang/mock v1.4.0/go.mod h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt3cw=
+github.com/golang/mock v1.4.1/go.mod h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt3cw=
+github.com/golang/mock v1.4.3/go.mod h1:UOMv5ysSaYNkG+OFQykRIcU/QvvxJf3p21QfJ2Bt3cw=
+github.com/golang/mock v1.4.4/go.mod h1:l3mdAwkq5BuhzHwde/uurv3sEJeZMXNpwsxVWU71h+4=
+github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.3.3/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw=
+github.com/golang/protobuf v1.3.4/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw=
+github.com/golang/protobuf v1.3.5/go.mod h1:6O5/vntMXwX2lRkT1hjjk0nAC1IDOTvTlVgjlRvqsdk=
+github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
+github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
+github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=
+github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w=
+github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0=
+github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8=
+github.com/golang/protobuf v1.4.2 h1:+Z5KGCizgyZCbGh1KZqA0fcLLkwbsjIzS4aV2v7wJX0=
+github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
+github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
+github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
+github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
+github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
+github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
+github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.4.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.1 h1:JFrFEBb2xKufg6XkJsJr+WbKb4FQlURi5RUcBveYu9k=
+github.com/google/go-cmp v0.5.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/martian v2.1.0+incompatible/go.mod h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs=
+github.com/google/martian/v3 v3.0.0/go.mod h1:y5Zk1BBys9G+gd6Jrk0W3cC1+ELVxBWuIGO+w/tUAp0=
+github.com/google/pprof v0.0.0-20181206194817-3ea8567a2e57/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc=
+github.com/google/pprof v0.0.0-20190515194954-54271f7e092f/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc=
+github.com/google/pprof v0.0.0-20191218002539-d4f498aebedc/go.mod h1:ZgVRPoUq/hfqzAqh7sHMqb3I9Rq5C59dIz2SbBwJ4eM=
+github.com/google/pprof v0.0.0-20200212024743-f11f1df84d12/go.mod h1:ZgVRPoUq/hfqzAqh7sHMqb3I9Rq5C59dIz2SbBwJ4eM=
+github.com/google/pprof v0.0.0-20200229191704-1ebb73c60ed3/go.mod h1:ZgVRPoUq/hfqzAqh7sHMqb3I9Rq5C59dIz2SbBwJ4eM=
+github.com/google/pprof v0.0.0-20200430221834-fc25d7d30c6d/go.mod h1:ZgVRPoUq/hfqzAqh7sHMqb3I9Rq5C59dIz2SbBwJ4eM=
+github.com/google/pprof v0.0.0-20200708004538-1a94d8640e99/go.mod h1:ZgVRPoUq/hfqzAqh7sHMqb3I9Rq5C59dIz2SbBwJ4eM=
+github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
+github.com/googleapis/gax-go/v2 v2.0.4/go.mod h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+vpHVxEJEs9eg=
+github.com/googleapis/gax-go/v2 v2.0.5/go.mod h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk=
+github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
+github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
+github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
+github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
+github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk=
+github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
+github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
-github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
+github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
+github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
+github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
+go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
+go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
+go.opencensus.io v0.22.2/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
+go.opencensus.io v0.22.3/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
+go.opencensus.io v0.22.4/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20190605123033-f99c8df09eb5/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
+golang.org/x/exp v0.0.0-20190306152737-a1d7652674e8/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
+golang.org/x/exp v0.0.0-20190510132918-efd6b22b2522/go.mod h1:ZjyILWgesfNpC6sMxTJOJm9Kp84zZh5NQWvqDGG3Qr8=
+golang.org/x/exp v0.0.0-20190829153037-c13cbed26979/go.mod h1:86+5VVa7VpoJ4kLfm080zCjGlMRFzhUhsZKEZO7MGek=
+golang.org/x/exp v0.0.0-20191030013958-a1ab85dbe136/go.mod h1:JXzH8nQsPlswgeRAPE3MuO9GYsAcnJvJ4vnMwN/5qkY=
+golang.org/x/exp v0.0.0-20191129062945-2f5052295587/go.mod h1:2RIsYlXP63K8oxa1u096TMicItID8zy7Y6sNkU49FU4=
+golang.org/x/exp v0.0.0-20191227195350-da58074b4299/go.mod h1:2RIsYlXP63K8oxa1u096TMicItID8zy7Y6sNkU49FU4=
+golang.org/x/exp v0.0.0-20200119233911-0405dc783f0a/go.mod h1:2RIsYlXP63K8oxa1u096TMicItID8zy7Y6sNkU49FU4=
+golang.org/x/exp v0.0.0-20200207192155-f17229e696bd/go.mod h1:J/WKrq2StrnmMY6+EHIKF9dgMWnmCNThgcyBT1FY9mM=
+golang.org/x/exp v0.0.0-20200224162631-6cc2880d07d6/go.mod h1:3jZMyOhIsHpP37uCMkUooju7aAi5cS1Q23tOzKc+0MU=
+golang.org/x/image v0.0.0-20190227222117-0694c2d4d067/go.mod h1:kZ7UVZpmo3dzQBMxlp+ypCbDeSB+sBbTgSJuh5dn5js=
+golang.org/x/image v0.0.0-20190802002840-cff245a6509b/go.mod h1:FeLwcggjj3mMvU+oOTbSwawSJRM1uh48EjtB4UJZlP0=
+golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
+golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
+golang.org/x/lint v0.0.0-20190301231843-5614ed5bae6f/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
+golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
+golang.org/x/lint v0.0.0-20190409202823-959b441ac422/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
+golang.org/x/lint v0.0.0-20190909230951-414d861bb4ac/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
+golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
+golang.org/x/lint v0.0.0-20191125180803-fdd1cda4f05f/go.mod h1:5qLYkcX4OjUUV8bRuDixDT3tpyyb+LUpUlRWLxfhWrs=
+golang.org/x/lint v0.0.0-20200130185559-910be7a94367/go.mod h1:3xt1FjdF8hUf6vQPIChWIBhFzV8gjjsPE/fR3IyQdNY=
+golang.org/x/lint v0.0.0-20200302205851-738671d3881b/go.mod h1:3xt1FjdF8hUf6vQPIChWIBhFzV8gjjsPE/fR3IyQdNY=
+golang.org/x/mobile v0.0.0-20190312151609-d3739f865fa6/go.mod h1:z+o9i4GpDbdi3rU15maQ/Ox0txvL9dWGYEHz965HBQE=
+golang.org/x/mobile v0.0.0-20190719004257-d2bd2a29d028/go.mod h1:E/iHnbuqvinMTCcRqshq8CkpyQDoeVncDDYHnLhea+o=
+golang.org/x/mod v0.0.0-20190513183733-4bf6d317e70e/go.mod h1:mXi4GBBbnImb6dmsKGUJ2LatrhH/nqhxcFungHvyanc=
+golang.org/x/mod v0.1.0/go.mod h1:0QHyrYULN0/3qlju5TqG8bIK38QM8yzMo5ekMj3DlcY=
+golang.org/x/mod v0.1.1-0.20191105210325-c90efee705ee/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg=
+golang.org/x/mod v0.1.1-0.20191107180719-034126e5016b/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg=
+golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
+golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
+golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190501004415-9ce7a6920f09/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190503192946-f4e77d36d62c/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190603091049-60506f45cf65/go.mod h1:HSz+uSET+XFnRR8LxR5pz3Of3rY3CfYBVs4xY44aLks=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20190628185345-da137c7871d7/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20190724013045-ca1201d0de80/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20191209160850-c0dbc17a3553/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200202094626-16171245cfb2/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200222125558-5a598a2470a0/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200301022130-244492dfa37a/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200324143707-d3edc9973b7e/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200501053045-e0ff5e5a1de5/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200506145744-7e3656a0809f/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200513185701-a91f0712d120/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200520182314-0ba52f642ac2/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
+golang.org/x/net v0.0.0-20200625001655-4c5254603344/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
+golang.org/x/net v0.0.0-20200707034311-ab3426394381/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
+golang.org/x/net v0.0.0-20200822124328-c89045814202 h1:VvcQYSHwXgi7W+TpUR6A9g6Up98WAHf3f/ulnJ62IyA=
+golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
+golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
+golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
+golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
+golang.org/x/oauth2 v0.0.0-20191202225959-858c2ad4c8b6/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
+golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
+golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558 h1:D7nTwh4J0i+5mW4Zjzn5omvlr6YBcWywE6KOcatyNxY=
+golang.org/x/oauth2 v0.0.0-20210323180902-22b0adad7558/go.mod h1:KelEdhl1UZF7XfJ4dDtk6s++YSgaE7mD/BuKKDLBl4A=
+golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20200317015054-43a5402ce75a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190312061237-fead79001313/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190502145724-3ef323f4f1fd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190507160741-ecd444e8653b/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190606165138-5da285871e9c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190624142023-c5567b49c5d0/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190726091711-fc99dfbffb4e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191001151750-bb3f8db39f24/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191204072324-ce4227a45e2e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191228213918-04cbcbbfeed8/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200113162924-86b910548bc1/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200122134326-e047566fdf82/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200202164722-d101bd2416d5/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200212091648-12a6c2dcc1e4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200302150141-5c8b2ff67527/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200331124033-c3d80250170d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200501052902-10377860bb8e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200511232937-7e40ca221e25/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200515095857-1151b9dac4a9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200523222454-059865788121/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200803210538-64077c9b5642/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
+golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
+golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
+golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
+golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
+golang.org/x/tools v0.0.0-20190312151545-0bb0c0a6e846/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
+golang.org/x/tools v0.0.0-20190312170243-e65039ee4138/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
+golang.org/x/tools v0.0.0-20190425150028-36563e24a262/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
+golang.org/x/tools v0.0.0-20190506145303-2d16b83fe98c/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
+golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
+golang.org/x/tools v0.0.0-20190606124116-d0a3d012864b/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
+golang.org/x/tools v0.0.0-20190621195816-6e04913cbbac/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
+golang.org/x/tools v0.0.0-20190628153133-6cdbf07be9d0/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
+golang.org/x/tools v0.0.0-20190816200558-6889da9d5479/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20190911174233-4f2ddba30aff/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191012152004-8de300cfc20a/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191113191852-77e3bb0ad9e7/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191115202509-3a792d9c32b2/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191125144606-a911d9008d1f/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191130070609-6e064ea0cf2d/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191216173652-a0e659d51361/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20191227053925-7b8e75db28f4/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200117161641-43d50277825c/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200122220014-bf1340f18c4a/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200204074204-1cc6d1ef6c74/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200207183749-b753a1ba74fa/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200212150539-ea181f53ac56/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200224181240-023911ca70b2/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200227222343-706bc42d1f0d/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/tools v0.0.0-20200304193943-95d2e580d8eb/go.mod h1:o4KQGtdN14AW+yjsvvwRTJJuXz8XRtIHtEnmAXLyFUw=
+golang.org/x/tools v0.0.0-20200312045724-11d5b4c81c7d/go.mod h1:o4KQGtdN14AW+yjsvvwRTJJuXz8XRtIHtEnmAXLyFUw=
+golang.org/x/tools v0.0.0-20200331025713-a30bf2db82d4/go.mod h1:Sl4aGygMT6LrqrWclx+PTx3U+LnKx/seiNR+3G19Ar8=
+golang.org/x/tools v0.0.0-20200501065659-ab2804fb9c9d/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20200512131952-2bc93b1c0c88/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20200515010526-7d3b6ebf133d/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20200618134242-20370b0cb4b2/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20200729194436-6467de6f59a7/go.mod h1:njjCfa9FT2d7l9Bc6FUM5FLjQPp3cFF28FI3qnDFljA=
+golang.org/x/tools v0.0.0-20200804011535-6c149bb5ef0d/go.mod h1:njjCfa9FT2d7l9Bc6FUM5FLjQPp3cFF28FI3qnDFljA=
+golang.org/x/tools v0.0.0-20200825202427-b303f430e36d/go.mod h1:njjCfa9FT2d7l9Bc6FUM5FLjQPp3cFF28FI3qnDFljA=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+google.golang.org/api v0.4.0/go.mod h1:8k5glujaEP+g9n7WNsDg8QP6cUVNI86fCNMcbazEtwE=
+google.golang.org/api v0.7.0/go.mod h1:WtwebWUNSVBH/HAw79HIFXZNqEvBhG+Ra+ax0hx3E3M=
+google.golang.org/api v0.8.0/go.mod h1:o4eAsZoiT+ibD93RtjEohWalFOjRDx6CVaqeizhEnKg=
+google.golang.org/api v0.9.0/go.mod h1:o4eAsZoiT+ibD93RtjEohWalFOjRDx6CVaqeizhEnKg=
+google.golang.org/api v0.13.0/go.mod h1:iLdEw5Ide6rF15KTC1Kkl0iskquN2gFfn9o9XIsbkAI=
+google.golang.org/api v0.14.0/go.mod h1:iLdEw5Ide6rF15KTC1Kkl0iskquN2gFfn9o9XIsbkAI=
+google.golang.org/api v0.15.0/go.mod h1:iLdEw5Ide6rF15KTC1Kkl0iskquN2gFfn9o9XIsbkAI=
+google.golang.org/api v0.17.0/go.mod h1:BwFmGc8tA3vsd7r/7kR8DY7iEEGSU04BFxCo5jP/sfE=
+google.golang.org/api v0.18.0/go.mod h1:BwFmGc8tA3vsd7r/7kR8DY7iEEGSU04BFxCo5jP/sfE=
+google.golang.org/api v0.19.0/go.mod h1:BwFmGc8tA3vsd7r/7kR8DY7iEEGSU04BFxCo5jP/sfE=
+google.golang.org/api v0.20.0/go.mod h1:BwFmGc8tA3vsd7r/7kR8DY7iEEGSU04BFxCo5jP/sfE=
+google.golang.org/api v0.22.0/go.mod h1:BwFmGc8tA3vsd7r/7kR8DY7iEEGSU04BFxCo5jP/sfE=
+google.golang.org/api v0.24.0/go.mod h1:lIXQywCXRcnZPGlsd8NbLnOjtAoL6em04bJ9+z0MncE=
+google.golang.org/api v0.28.0/go.mod h1:lIXQywCXRcnZPGlsd8NbLnOjtAoL6em04bJ9+z0MncE=
+google.golang.org/api v0.29.0/go.mod h1:Lcubydp8VUV7KeIHD9z2Bys/sm/vGKnG1UHuDBSrHWM=
+google.golang.org/api v0.30.0/go.mod h1:QGmEvQ87FHZNiUVJkT14jQNYJ4ZJjdRF23ZXz5138Fc=
+google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
+google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/appengine v1.5.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/appengine v1.6.1/go.mod h1:i06prIuMbXzDqacNJfV5OdTW448YApPu5ww/cMBSeb0=
+google.golang.org/appengine v1.6.5/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
+google.golang.org/appengine v1.6.6 h1:lMO5rYAqUxkmaj76jAkRUvt5JZgFymx/+Q5Mzfivuhc=
+google.golang.org/appengine v1.6.6/go.mod h1:8WjMMxjGQR8xUklV/ARdw2HLXBOI7O7uCIDZVag1xfc=
+google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
+google.golang.org/genproto v0.0.0-20190307195333-5fe7a883aa19/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
+google.golang.org/genproto v0.0.0-20190418145605-e7d98fc518a7/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
+google.golang.org/genproto v0.0.0-20190425155659-357c62f0e4bb/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
+google.golang.org/genproto v0.0.0-20190502173448-54afdca5d873/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
+google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
+google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
+google.golang.org/genproto v0.0.0-20190911173649-1774047e7e51/go.mod h1:IbNlFCBrqXvoKpeg0TB2l7cyZUmoaFKYIwrEpbDKLA8=
+google.golang.org/genproto v0.0.0-20191108220845-16a3f7862a1a/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
+google.golang.org/genproto v0.0.0-20191115194625-c23dd37a84c9/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
+google.golang.org/genproto v0.0.0-20191216164720-4f79533eabd1/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
+google.golang.org/genproto v0.0.0-20191230161307-f3c370f40bfb/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
+google.golang.org/genproto v0.0.0-20200115191322-ca5a22157cba/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
+google.golang.org/genproto v0.0.0-20200122232147-0452cf42e150/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
+google.golang.org/genproto v0.0.0-20200204135345-fa8e72b47b90/go.mod h1:GmwEX6Z4W5gMy59cAlVYjN9JhxgbQH6Gn+gFDQe2lzA=
+google.golang.org/genproto v0.0.0-20200212174721-66ed5ce911ce/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200224152610-e50cd9704f63/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200228133532-8c2c7df3a383/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200305110556-506484158171/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200312145019-da6875a35672/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200331122359-1ee6d9798940/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200430143042-b979b6f78d84/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200511104702-f5ebc3bea380/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c=
+google.golang.org/genproto v0.0.0-20200515170657-fc4c6c6a6587/go.mod h1:YsZOwe1myG/8QRHRsmBRE1LrgQY60beZKjly0O1fX9U=
+google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo=
+google.golang.org/genproto v0.0.0-20200618031413-b414f8b61790/go.mod h1:jDfRM7FcilCzHH/e9qn6dsT145K34l5v+OpcnNgKAAA=
+google.golang.org/genproto v0.0.0-20200729003335-053ba62fc06f/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
+google.golang.org/genproto v0.0.0-20200804131852-c06518451d9c/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
+google.golang.org/genproto v0.0.0-20200825200019-8632dd797987/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
+google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
+google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38=
+google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=
+google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg=
+google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY=
+google.golang.org/grpc v1.26.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
+google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
+google.golang.org/grpc v1.27.1/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
+google.golang.org/grpc v1.28.0/go.mod h1:rpkK4SK4GF4Ach/+MFLZUBavHOvF2JJB5uozKKal+60=
+google.golang.org/grpc v1.29.1/go.mod h1:itym6AZVZYACWQqET3MqgPpjcuV5QH3BxFS3IjizoKk=
+google.golang.org/grpc v1.30.0/go.mod h1:N36X2cJ7JwdamYAgDz+s+rVMFjt3numwzf/HckM8pak=
+google.golang.org/grpc v1.31.0/go.mod h1:N36X2cJ7JwdamYAgDz+s+rVMFjt3numwzf/HckM8pak=
+google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
+google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
+google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
+google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE=
+google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo=
+google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
+google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
+google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
+google.golang.org/protobuf v1.24.0/go.mod h1:r/3tXBNzIEhYS9I1OUVjXDlt8tc493IdKGjtUeSXeh4=
+google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c=
+google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
-gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.0-20190418001031-e561f6794a2a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.1-2019.2.3/go.mod h1:a3bituU0lyd329TUQxRnasdCoJDkEUEAqEt0JzvZhAg=
+honnef.co/go/tools v0.0.1-2020.1.3/go.mod h1:X/FiERA/W4tHapMX5mGpAtMSVEeEUOyHaw9vFzvIQ3k=
+honnef.co/go/tools v0.0.1-2020.1.4/go.mod h1:X/FiERA/W4tHapMX5mGpAtMSVEeEUOyHaw9vFzvIQ3k=
+rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
+rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
+rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=
--- a/model_models_orchestrator_task.go
+++ b/model_models_orchestrator_task.go
@ -1,213 +0,0 @@
-/*
-Anthrove Orchestrator API
-
-This service handles the communication between the manager and the plugs
-
-API version: 0.1-PREVIEW
-Contact: support@anthrove.art
-*/
-
-// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
-
-package openapi
-
-import (
-	"bytes"
-	"encoding/json"
-	"fmt"
-)
-
-// checks if the ModelsOrchestratorTask type satisfies the MappedNullable interface at compile time
-var _ MappedNullable = &ModelsOrchestratorTask{}
-
-// ModelsOrchestratorTask struct for ModelsOrchestratorTask
-type ModelsOrchestratorTask struct {
-	AnthroveUserId string         `json:"anthrove_user_id"`
-	DeepScrape     bool           `json:"deep_scrape"`
-	PlugTask       ModelsPlugTask `json:"plug_task"`
-}
-
-type _ModelsOrchestratorTask ModelsOrchestratorTask
-
-// NewModelsOrchestratorTask instantiates a new ModelsOrchestratorTask object
-// This constructor will assign default values to properties that have it defined,
-// and makes sure properties required by API are set, but the set of arguments
-// will change when the set of required properties is changed
-func NewModelsOrchestratorTask(anthroveUserId string, deepScrape bool, plugTask ModelsPlugTask) *ModelsOrchestratorTask {
-	this := ModelsOrchestratorTask{}
-	this.AnthroveUserId = anthroveUserId
-	this.DeepScrape = deepScrape
-	this.PlugTask = plugTask
-	return &this
-}
-
-// NewModelsOrchestratorTaskWithDefaults instantiates a new ModelsOrchestratorTask object
-// This constructor will only assign default values to properties that have it defined,
-// but it doesn't guarantee that properties required by API are set
-func NewModelsOrchestratorTaskWithDefaults() *ModelsOrchestratorTask {
-	this := ModelsOrchestratorTask{}
-	return &this
-}
-
-// GetAnthroveUserId returns the AnthroveUserId field value
-func (o *ModelsOrchestratorTask) GetAnthroveUserId() string {
-	if o == nil {
-		var ret string
-		return ret
-	}
-
-	return o.AnthroveUserId
-}
-
-// GetAnthroveUserIdOk returns a tuple with the AnthroveUserId field value
-// and a boolean to check if the value has been set.
-func (o *ModelsOrchestratorTask) GetAnthroveUserIdOk() (*string, bool) {
-	if o == nil {
-		return nil, false
-	}
-	return &o.AnthroveUserId, true
-}
-
-// SetAnthroveUserId sets field value
-func (o *ModelsOrchestratorTask) SetAnthroveUserId(v string) {
-	o.AnthroveUserId = v
-}
-
-// GetDeepScrape returns the DeepScrape field value
-func (o *ModelsOrchestratorTask) GetDeepScrape() bool {
-	if o == nil {
-		var ret bool
-		return ret
-	}
-
-	return o.DeepScrape
-}
-
-// GetDeepScrapeOk returns a tuple with the DeepScrape field value
-// and a boolean to check if the value has been set.
-func (o *ModelsOrchestratorTask) GetDeepScrapeOk() (*bool, bool) {
-	if o == nil {
-		return nil, false
-	}
-	return &o.DeepScrape, true
-}
-
-// SetDeepScrape sets field value
-func (o *ModelsOrchestratorTask) SetDeepScrape(v bool) {
-	o.DeepScrape = v
-}
-
-// GetPlugTask returns the PlugTask field value
-func (o *ModelsOrchestratorTask) GetPlugTask() ModelsPlugTask {
-	if o == nil {
-		var ret ModelsPlugTask
-		return ret
-	}
-
-	return o.PlugTask
-}
-
-// GetPlugTaskOk returns a tuple with the PlugTask field value
-// and a boolean to check if the value has been set.
-func (o *ModelsOrchestratorTask) GetPlugTaskOk() (*ModelsPlugTask, bool) {
-	if o == nil {
-		return nil, false
-	}
-	return &o.PlugTask, true
-}
-
-// SetPlugTask sets field value
-func (o *ModelsOrchestratorTask) SetPlugTask(v ModelsPlugTask) {
-	o.PlugTask = v
-}
-
-func (o ModelsOrchestratorTask) MarshalJSON() ([]byte, error) {
-	toSerialize, err := o.ToMap()
-	if err != nil {
-		return []byte{}, err
-	}
-	return json.Marshal(toSerialize)
-}
-
-func (o ModelsOrchestratorTask) ToMap() (map[string]interface{}, error) {
-	toSerialize := map[string]interface{}{}
-	toSerialize["anthrove_user_id"] = o.AnthroveUserId
-	toSerialize["deep_scrape"] = o.DeepScrape
-	toSerialize["plug_task"] = o.PlugTask
-	return toSerialize, nil
-}
-
-func (o *ModelsOrchestratorTask) UnmarshalJSON(data []byte) (err error) {
-	// This validates that all required properties are included in the JSON object
-	// by unmarshalling the object into a generic map with string keys and checking
-	// that every required field exists as a key in the generic map.
-	requiredProperties := []string{
-		"anthrove_user_id",
-		"deep_scrape",
-		"plug_task",
-	}
-
-	allProperties := make(map[string]interface{})
-
-	err = json.Unmarshal(data, &allProperties)
-
-	if err != nil {
-		return err
-	}
-
-	for _, requiredProperty := range requiredProperties {
-		if _, exists := allProperties[requiredProperty]; !exists {
-			return fmt.Errorf("no value given for required property %v", requiredProperty)
-		}
-	}
-
-	varModelsOrchestratorTask := _ModelsOrchestratorTask{}
-
-	decoder := json.NewDecoder(bytes.NewReader(data))
-	decoder.DisallowUnknownFields()
-	err = decoder.Decode(&varModelsOrchestratorTask)
-
-	if err != nil {
-		return err
-	}
-
-	*o = ModelsOrchestratorTask(varModelsOrchestratorTask)
-
-	return err
-}
-
-type NullableModelsOrchestratorTask struct {
-	value *ModelsOrchestratorTask
-	isSet bool
-}
-
-func (v NullableModelsOrchestratorTask) Get() *ModelsOrchestratorTask {
-	return v.value
-}
-
-func (v *NullableModelsOrchestratorTask) Set(val *ModelsOrchestratorTask) {
-	v.value = val
-	v.isSet = true
-}
-
-func (v NullableModelsOrchestratorTask) IsSet() bool {
-	return v.isSet
-}
-
-func (v *NullableModelsOrchestratorTask) Unset() {
-	v.value = nil
-	v.isSet = false
-}
-
-func NewNullableModelsOrchestratorTask(val *ModelsOrchestratorTask) *NullableModelsOrchestratorTask {
-	return &NullableModelsOrchestratorTask{value: val, isSet: true}
-}
-
-func (v NullableModelsOrchestratorTask) MarshalJSON() ([]byte, error) {
-	return json.Marshal(v.value)
-}
-
-func (v *NullableModelsOrchestratorTask) UnmarshalJSON(src []byte) error {
-	v.isSet = true
-	return json.Unmarshal(src, &v.value)
-}
--- a/model_models_plug_task.go
+++ b/model_models_plug_task.go
@ -1,229 +0,0 @@
-/*
-Anthrove Orchestrator API
-
-This service handles the communication between the manager and the plugs
-
-API version: 0.1-PREVIEW
-Contact: support@anthrove.art
-*/
-
-// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
-
-package openapi
-
-import (
-	"bytes"
-	"encoding/json"
-	"fmt"
-)
-
-// checks if the ModelsPlugTask type satisfies the MappedNullable interface at compile time
-var _ MappedNullable = &ModelsPlugTask{}
-
-// ModelsPlugTask struct for ModelsPlugTask
-type ModelsPlugTask struct {
-	Id        *string              `json:"id,omitempty"`
-	TaskState *ModelsPlugTaskState `json:"task_state,omitempty"`
-	UserId    string               `json:"user_id"`
-}
-
-type _ModelsPlugTask ModelsPlugTask
-
-// NewModelsPlugTask instantiates a new ModelsPlugTask object
-// This constructor will assign default values to properties that have it defined,
-// and makes sure properties required by API are set, but the set of arguments
-// will change when the set of required properties is changed
-func NewModelsPlugTask(userId string) *ModelsPlugTask {
-	this := ModelsPlugTask{}
-	this.UserId = userId
-	return &this
-}
-
-// NewModelsPlugTaskWithDefaults instantiates a new ModelsPlugTask object
-// This constructor will only assign default values to properties that have it defined,
-// but it doesn't guarantee that properties required by API are set
-func NewModelsPlugTaskWithDefaults() *ModelsPlugTask {
-	this := ModelsPlugTask{}
-	return &this
-}
-
-// GetId returns the Id field value if set, zero value otherwise.
-func (o *ModelsPlugTask) GetId() string {
-	if o == nil || IsNil(o.Id) {
-		var ret string
-		return ret
-	}
-	return *o.Id
-}
-
-// GetIdOk returns a tuple with the Id field value if set, nil otherwise
-// and a boolean to check if the value has been set.
-func (o *ModelsPlugTask) GetIdOk() (*string, bool) {
-	if o == nil || IsNil(o.Id) {
-		return nil, false
-	}
-	return o.Id, true
-}
-
-// HasId returns a boolean if a field has been set.
-func (o *ModelsPlugTask) HasId() bool {
-	if o != nil && !IsNil(o.Id) {
-		return true
-	}
-
-	return false
-}
-
-// SetId gets a reference to the given string and assigns it to the Id field.
-func (o *ModelsPlugTask) SetId(v string) {
-	o.Id = &v
-}
-
-// GetTaskState returns the TaskState field value if set, zero value otherwise.
-func (o *ModelsPlugTask) GetTaskState() ModelsPlugTaskState {
-	if o == nil || IsNil(o.TaskState) {
-		var ret ModelsPlugTaskState
-		return ret
-	}
-	return *o.TaskState
-}
-
-// GetTaskStateOk returns a tuple with the TaskState field value if set, nil otherwise
-// and a boolean to check if the value has been set.
-func (o *ModelsPlugTask) GetTaskStateOk() (*ModelsPlugTaskState, bool) {
-	if o == nil || IsNil(o.TaskState) {
-		return nil, false
-	}
-	return o.TaskState, true
-}
-
-// HasTaskState returns a boolean if a field has been set.
-func (o *ModelsPlugTask) HasTaskState() bool {
-	if o != nil && !IsNil(o.TaskState) {
-		return true
-	}
-
-	return false
-}
-
-// SetTaskState gets a reference to the given ModelsPlugTaskState and assigns it to the TaskState field.
-func (o *ModelsPlugTask) SetTaskState(v ModelsPlugTaskState) {
-	o.TaskState = &v
-}
-
-// GetUserId returns the UserId field value
-func (o *ModelsPlugTask) GetUserId() string {
-	if o == nil {
-		var ret string
-		return ret
-	}
-
-	return o.UserId
-}
-
-// GetUserIdOk returns a tuple with the UserId field value
-// and a boolean to check if the value has been set.
-func (o *ModelsPlugTask) GetUserIdOk() (*string, bool) {
-	if o == nil {
-		return nil, false
-	}
-	return &o.UserId, true
-}
-
-// SetUserId sets field value
-func (o *ModelsPlugTask) SetUserId(v string) {
-	o.UserId = v
-}
-
-func (o ModelsPlugTask) MarshalJSON() ([]byte, error) {
-	toSerialize, err := o.ToMap()
-	if err != nil {
-		return []byte{}, err
-	}
-	return json.Marshal(toSerialize)
-}
-
-func (o ModelsPlugTask) ToMap() (map[string]interface{}, error) {
-	toSerialize := map[string]interface{}{}
-	if !IsNil(o.Id) {
-		toSerialize["id"] = o.Id
-	}
-	if !IsNil(o.TaskState) {
-		toSerialize["task_state"] = o.TaskState
-	}
-	toSerialize["user_id"] = o.UserId
-	return toSerialize, nil
-}
-
-func (o *ModelsPlugTask) UnmarshalJSON(data []byte) (err error) {
-	// This validates that all required properties are included in the JSON object
-	// by unmarshalling the object into a generic map with string keys and checking
-	// that every required field exists as a key in the generic map.
-	requiredProperties := []string{
-		"user_id",
-	}
-
-	allProperties := make(map[string]interface{})
-
-	err = json.Unmarshal(data, &allProperties)
-
-	if err != nil {
-		return err
-	}
-
-	for _, requiredProperty := range requiredProperties {
-		if _, exists := allProperties[requiredProperty]; !exists {
-			return fmt.Errorf("no value given for required property %v", requiredProperty)
-		}
-	}
-
-	varModelsPlugTask := _ModelsPlugTask{}
-
-	decoder := json.NewDecoder(bytes.NewReader(data))
-	decoder.DisallowUnknownFields()
-	err = decoder.Decode(&varModelsPlugTask)
-
-	if err != nil {
-		return err
-	}
-
-	*o = ModelsPlugTask(varModelsPlugTask)
-
-	return err
-}
-
-type NullableModelsPlugTask struct {
-	value *ModelsPlugTask
-	isSet bool
-}
-
-func (v NullableModelsPlugTask) Get() *ModelsPlugTask {
-	return v.value
-}
-
-func (v *NullableModelsPlugTask) Set(val *ModelsPlugTask) {
-	v.value = val
-	v.isSet = true
-}
-
-func (v NullableModelsPlugTask) IsSet() bool {
-	return v.isSet
-}
-
-func (v *NullableModelsPlugTask) Unset() {
-	v.value = nil
-	v.isSet = false
-}
-
-func NewNullableModelsPlugTask(val *ModelsPlugTask) *NullableModelsPlugTask {
-	return &NullableModelsPlugTask{value: val, isSet: true}
-}
-
-func (v NullableModelsPlugTask) MarshalJSON() ([]byte, error) {
-	return json.Marshal(v.value)
-}
-
-func (v *NullableModelsPlugTask) UnmarshalJSON(src []byte) error {
-	v.isSet = true
-	return json.Unmarshal(src, &v.value)
-}
--- a/model_models_plug_task_state.go
+++ b/model_models_plug_task_state.go
@ -1,115 +0,0 @@
-/*
-Anthrove Orchestrator API
-
-This service handles the communication between the manager and the plugs
-
-API version: 0.1-PREVIEW
-Contact: support@anthrove.art
-*/
-
-// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
-
-package openapi
-
-import (
-	"encoding/json"
-	"fmt"
-)
-
-// ModelsPlugTaskState the model 'ModelsPlugTaskState'
-type ModelsPlugTaskState string
-
-// List of models.PlugTaskState
-const (
-	PlugTaskStateUnknown ModelsPlugTaskState = "UNKNOWN"
-	PlugTaskStateStarted ModelsPlugTaskState = "STARTED"
-	PlugTaskStateRunning ModelsPlugTaskState = "RUNNING"
-	PlugTaskStateStopped ModelsPlugTaskState = "STOPPED"
-)
-
-// All allowed values of ModelsPlugTaskState enum
-var AllowedModelsPlugTaskStateEnumValues = []ModelsPlugTaskState{
-	"UNKNOWN",
-	"STARTED",
-	"RUNNING",
-	"STOPPED",
-}
-
-func (v *ModelsPlugTaskState) UnmarshalJSON(src []byte) error {
-	var value string
-	err := json.Unmarshal(src, &value)
-	if err != nil {
-		return err
-	}
-	enumTypeValue := ModelsPlugTaskState(value)
-	for _, existing := range AllowedModelsPlugTaskStateEnumValues {
-		if existing == enumTypeValue {
-			*v = enumTypeValue
-			return nil
-		}
-	}
-
-	return fmt.Errorf("%+v is not a valid ModelsPlugTaskState", value)
-}
-
-// NewModelsPlugTaskStateFromValue returns a pointer to a valid ModelsPlugTaskState
-// for the value passed as argument, or an error if the value passed is not allowed by the enum
-func NewModelsPlugTaskStateFromValue(v string) (*ModelsPlugTaskState, error) {
-	ev := ModelsPlugTaskState(v)
-	if ev.IsValid() {
-		return &ev, nil
-	} else {
-		return nil, fmt.Errorf("invalid value '%v' for ModelsPlugTaskState: valid values are %v", v, AllowedModelsPlugTaskStateEnumValues)
-	}
-}
-
-// IsValid return true if the value is valid for the enum, false otherwise
-func (v ModelsPlugTaskState) IsValid() bool {
-	for _, existing := range AllowedModelsPlugTaskStateEnumValues {
-		if existing == v {
-			return true
-		}
-	}
-	return false
-}
-
-// Ptr returns reference to models.PlugTaskState value
-func (v ModelsPlugTaskState) Ptr() *ModelsPlugTaskState {
-	return &v
-}
-
-type NullableModelsPlugTaskState struct {
-	value *ModelsPlugTaskState
-	isSet bool
-}
-
-func (v NullableModelsPlugTaskState) Get() *ModelsPlugTaskState {
-	return v.value
-}
-
-func (v *NullableModelsPlugTaskState) Set(val *ModelsPlugTaskState) {
-	v.value = val
-	v.isSet = true
-}
-
-func (v NullableModelsPlugTaskState) IsSet() bool {
-	return v.isSet
-}
-
-func (v *NullableModelsPlugTaskState) Unset() {
-	v.value = nil
-	v.isSet = false
-}
-
-func NewNullableModelsPlugTaskState(val *ModelsPlugTaskState) *NullableModelsPlugTaskState {
-	return &NullableModelsPlugTaskState{value: val, isSet: true}
-}
-
-func (v NullableModelsPlugTaskState) MarshalJSON() ([]byte, error) {
-	return json.Marshal(v.value)
-}
-
-func (v *NullableModelsPlugTaskState) UnmarshalJSON(src []byte) error {
-	v.isSet = true
-	return json.Unmarshal(src, &v.value)
-}
--- a/model_task_message.go
+++ b/model_task_message.go
@ -0,0 +1,222 @@
+/*
+Anthrove Orchestrator API
+
+This service handles the communication between the manager and the plugs
+
+API version: 1.0
+Contact: support@anthrove.art
+*/
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package openapi
+
+import (
+	"encoding/json"
+)
+
+// TaskMessage struct for TaskMessage
+type TaskMessage struct {
+	Body         *string `json:"body,omitempty"`
+	CreatedAt    *string `json:"created_at,omitempty"`
+	Title        *string `json:"title,omitempty"`
+	UserSourceId *string `json:"user_source_id,omitempty"`
+}
+
+// NewTaskMessage instantiates a new TaskMessage object
+// This constructor will assign default values to properties that have it defined,
+// and makes sure properties required by API are set, but the set of arguments
+// will change when the set of required properties is changed
+func NewTaskMessage() *TaskMessage {
+	this := TaskMessage{}
+	return &this
+}
+
+// NewTaskMessageWithDefaults instantiates a new TaskMessage object
+// This constructor will only assign default values to properties that have it defined,
+// but it doesn't guarantee that properties required by API are set
+func NewTaskMessageWithDefaults() *TaskMessage {
+	this := TaskMessage{}
+	return &this
+}
+
+// GetBody returns the Body field value if set, zero value otherwise.
+func (o *TaskMessage) GetBody() string {
+	if o == nil || o.Body == nil {
+		var ret string
+		return ret
+	}
+	return *o.Body
+}
+
+// GetBodyOk returns a tuple with the Body field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskMessage) GetBodyOk() (*string, bool) {
+	if o == nil || o.Body == nil {
+		return nil, false
+	}
+	return o.Body, true
+}
+
+// HasBody returns a boolean if a field has been set.
+func (o *TaskMessage) HasBody() bool {
+	if o != nil && o.Body != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetBody gets a reference to the given string and assigns it to the Body field.
+func (o *TaskMessage) SetBody(v string) {
+	o.Body = &v
+}
+
+// GetCreatedAt returns the CreatedAt field value if set, zero value otherwise.
+func (o *TaskMessage) GetCreatedAt() string {
+	if o == nil || o.CreatedAt == nil {
+		var ret string
+		return ret
+	}
+	return *o.CreatedAt
+}
+
+// GetCreatedAtOk returns a tuple with the CreatedAt field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskMessage) GetCreatedAtOk() (*string, bool) {
+	if o == nil || o.CreatedAt == nil {
+		return nil, false
+	}
+	return o.CreatedAt, true
+}
+
+// HasCreatedAt returns a boolean if a field has been set.
+func (o *TaskMessage) HasCreatedAt() bool {
+	if o != nil && o.CreatedAt != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetCreatedAt gets a reference to the given string and assigns it to the CreatedAt field.
+func (o *TaskMessage) SetCreatedAt(v string) {
+	o.CreatedAt = &v
+}
+
+// GetTitle returns the Title field value if set, zero value otherwise.
+func (o *TaskMessage) GetTitle() string {
+	if o == nil || o.Title == nil {
+		var ret string
+		return ret
+	}
+	return *o.Title
+}
+
+// GetTitleOk returns a tuple with the Title field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskMessage) GetTitleOk() (*string, bool) {
+	if o == nil || o.Title == nil {
+		return nil, false
+	}
+	return o.Title, true
+}
+
+// HasTitle returns a boolean if a field has been set.
+func (o *TaskMessage) HasTitle() bool {
+	if o != nil && o.Title != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetTitle gets a reference to the given string and assigns it to the Title field.
+func (o *TaskMessage) SetTitle(v string) {
+	o.Title = &v
+}
+
+// GetUserSourceId returns the UserSourceId field value if set, zero value otherwise.
+func (o *TaskMessage) GetUserSourceId() string {
+	if o == nil || o.UserSourceId == nil {
+		var ret string
+		return ret
+	}
+	return *o.UserSourceId
+}
+
+// GetUserSourceIdOk returns a tuple with the UserSourceId field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskMessage) GetUserSourceIdOk() (*string, bool) {
+	if o == nil || o.UserSourceId == nil {
+		return nil, false
+	}
+	return o.UserSourceId, true
+}
+
+// HasUserSourceId returns a boolean if a field has been set.
+func (o *TaskMessage) HasUserSourceId() bool {
+	if o != nil && o.UserSourceId != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetUserSourceId gets a reference to the given string and assigns it to the UserSourceId field.
+func (o *TaskMessage) SetUserSourceId(v string) {
+	o.UserSourceId = &v
+}
+
+func (o TaskMessage) MarshalJSON() ([]byte, error) {
+	toSerialize := map[string]interface{}{}
+	if o.Body != nil {
+		toSerialize["body"] = o.Body
+	}
+	if o.CreatedAt != nil {
+		toSerialize["created_at"] = o.CreatedAt
+	}
+	if o.Title != nil {
+		toSerialize["title"] = o.Title
+	}
+	if o.UserSourceId != nil {
+		toSerialize["user_source_id"] = o.UserSourceId
+	}
+	return json.Marshal(toSerialize)
+}
+
+type NullableTaskMessage struct {
+	value *TaskMessage
+	isSet bool
+}
+
+func (v NullableTaskMessage) Get() *TaskMessage {
+	return v.value
+}
+
+func (v *NullableTaskMessage) Set(val *TaskMessage) {
+	v.value = val
+	v.isSet = true
+}
+
+func (v NullableTaskMessage) IsSet() bool {
+	return v.isSet
+}
+
+func (v *NullableTaskMessage) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+func NewNullableTaskMessage(val *TaskMessage) *NullableTaskMessage {
+	return &NullableTaskMessage{value: val, isSet: true}
+}
+
+func (v NullableTaskMessage) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+func (v *NullableTaskMessage) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}
--- a/model_task_response.go
+++ b/model_task_response.go
@ -0,0 +1,150 @@
+/*
+Anthrove Orchestrator API
+
+This service handles the communication between the manager and the plugs
+
+API version: 1.0
+Contact: support@anthrove.art
+*/
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package openapi
+
+import (
+	"encoding/json"
+)
+
+// TaskResponse struct for TaskResponse
+type TaskResponse struct {
+	PlugTaskId     *string `json:"plug_task_id,omitempty"`
+	PlugTaskStatus *string `json:"plug_task_status,omitempty"`
+}
+
+// NewTaskResponse instantiates a new TaskResponse object
+// This constructor will assign default values to properties that have it defined,
+// and makes sure properties required by API are set, but the set of arguments
+// will change when the set of required properties is changed
+func NewTaskResponse() *TaskResponse {
+	this := TaskResponse{}
+	return &this
+}
+
+// NewTaskResponseWithDefaults instantiates a new TaskResponse object
+// This constructor will only assign default values to properties that have it defined,
+// but it doesn't guarantee that properties required by API are set
+func NewTaskResponseWithDefaults() *TaskResponse {
+	this := TaskResponse{}
+	return &this
+}
+
+// GetPlugTaskId returns the PlugTaskId field value if set, zero value otherwise.
+func (o *TaskResponse) GetPlugTaskId() string {
+	if o == nil || o.PlugTaskId == nil {
+		var ret string
+		return ret
+	}
+	return *o.PlugTaskId
+}
+
+// GetPlugTaskIdOk returns a tuple with the PlugTaskId field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskResponse) GetPlugTaskIdOk() (*string, bool) {
+	if o == nil || o.PlugTaskId == nil {
+		return nil, false
+	}
+	return o.PlugTaskId, true
+}
+
+// HasPlugTaskId returns a boolean if a field has been set.
+func (o *TaskResponse) HasPlugTaskId() bool {
+	if o != nil && o.PlugTaskId != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetPlugTaskId gets a reference to the given string and assigns it to the PlugTaskId field.
+func (o *TaskResponse) SetPlugTaskId(v string) {
+	o.PlugTaskId = &v
+}
+
+// GetPlugTaskStatus returns the PlugTaskStatus field value if set, zero value otherwise.
+func (o *TaskResponse) GetPlugTaskStatus() string {
+	if o == nil || o.PlugTaskStatus == nil {
+		var ret string
+		return ret
+	}
+	return *o.PlugTaskStatus
+}
+
+// GetPlugTaskStatusOk returns a tuple with the PlugTaskStatus field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskResponse) GetPlugTaskStatusOk() (*string, bool) {
+	if o == nil || o.PlugTaskStatus == nil {
+		return nil, false
+	}
+	return o.PlugTaskStatus, true
+}
+
+// HasPlugTaskStatus returns a boolean if a field has been set.
+func (o *TaskResponse) HasPlugTaskStatus() bool {
+	if o != nil && o.PlugTaskStatus != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetPlugTaskStatus gets a reference to the given string and assigns it to the PlugTaskStatus field.
+func (o *TaskResponse) SetPlugTaskStatus(v string) {
+	o.PlugTaskStatus = &v
+}
+
+func (o TaskResponse) MarshalJSON() ([]byte, error) {
+	toSerialize := map[string]interface{}{}
+	if o.PlugTaskId != nil {
+		toSerialize["plug_task_id"] = o.PlugTaskId
+	}
+	if o.PlugTaskStatus != nil {
+		toSerialize["plug_task_status"] = o.PlugTaskStatus
+	}
+	return json.Marshal(toSerialize)
+}
+
+type NullableTaskResponse struct {
+	value *TaskResponse
+	isSet bool
+}
+
+func (v NullableTaskResponse) Get() *TaskResponse {
+	return v.value
+}
+
+func (v *NullableTaskResponse) Set(val *TaskResponse) {
+	v.value = val
+	v.isSet = true
+}
+
+func (v NullableTaskResponse) IsSet() bool {
+	return v.isSet
+}
+
+func (v *NullableTaskResponse) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+func NewNullableTaskResponse(val *TaskResponse) *NullableTaskResponse {
+	return &NullableTaskResponse{value: val, isSet: true}
+}
+
+func (v NullableTaskResponse) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+func (v *NullableTaskResponse) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}
--- a/model_task_start_task.go
+++ b/model_task_start_task.go
@ -0,0 +1,186 @@
+/*
+Anthrove Orchestrator API
+
+This service handles the communication between the manager and the plugs
+
+API version: 1.0
+Contact: support@anthrove.art
+*/
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package openapi
+
+import (
+	"encoding/json"
+)
+
+// TaskStartTask struct for TaskStartTask
+type TaskStartTask struct {
+	UserApiKey   *string `json:"user_api_key,omitempty"`
+	UserId       *string `json:"user_id,omitempty"`
+	UserSourceId *string `json:"user_source_id,omitempty"`
+}
+
+// NewTaskStartTask instantiates a new TaskStartTask object
+// This constructor will assign default values to properties that have it defined,
+// and makes sure properties required by API are set, but the set of arguments
+// will change when the set of required properties is changed
+func NewTaskStartTask() *TaskStartTask {
+	this := TaskStartTask{}
+	return &this
+}
+
+// NewTaskStartTaskWithDefaults instantiates a new TaskStartTask object
+// This constructor will only assign default values to properties that have it defined,
+// but it doesn't guarantee that properties required by API are set
+func NewTaskStartTaskWithDefaults() *TaskStartTask {
+	this := TaskStartTask{}
+	return &this
+}
+
+// GetUserApiKey returns the UserApiKey field value if set, zero value otherwise.
+func (o *TaskStartTask) GetUserApiKey() string {
+	if o == nil || o.UserApiKey == nil {
+		var ret string
+		return ret
+	}
+	return *o.UserApiKey
+}
+
+// GetUserApiKeyOk returns a tuple with the UserApiKey field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskStartTask) GetUserApiKeyOk() (*string, bool) {
+	if o == nil || o.UserApiKey == nil {
+		return nil, false
+	}
+	return o.UserApiKey, true
+}
+
+// HasUserApiKey returns a boolean if a field has been set.
+func (o *TaskStartTask) HasUserApiKey() bool {
+	if o != nil && o.UserApiKey != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetUserApiKey gets a reference to the given string and assigns it to the UserApiKey field.
+func (o *TaskStartTask) SetUserApiKey(v string) {
+	o.UserApiKey = &v
+}
+
+// GetUserId returns the UserId field value if set, zero value otherwise.
+func (o *TaskStartTask) GetUserId() string {
+	if o == nil || o.UserId == nil {
+		var ret string
+		return ret
+	}
+	return *o.UserId
+}
+
+// GetUserIdOk returns a tuple with the UserId field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskStartTask) GetUserIdOk() (*string, bool) {
+	if o == nil || o.UserId == nil {
+		return nil, false
+	}
+	return o.UserId, true
+}
+
+// HasUserId returns a boolean if a field has been set.
+func (o *TaskStartTask) HasUserId() bool {
+	if o != nil && o.UserId != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetUserId gets a reference to the given string and assigns it to the UserId field.
+func (o *TaskStartTask) SetUserId(v string) {
+	o.UserId = &v
+}
+
+// GetUserSourceId returns the UserSourceId field value if set, zero value otherwise.
+func (o *TaskStartTask) GetUserSourceId() string {
+	if o == nil || o.UserSourceId == nil {
+		var ret string
+		return ret
+	}
+	return *o.UserSourceId
+}
+
+// GetUserSourceIdOk returns a tuple with the UserSourceId field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *TaskStartTask) GetUserSourceIdOk() (*string, bool) {
+	if o == nil || o.UserSourceId == nil {
+		return nil, false
+	}
+	return o.UserSourceId, true
+}
+
+// HasUserSourceId returns a boolean if a field has been set.
+func (o *TaskStartTask) HasUserSourceId() bool {
+	if o != nil && o.UserSourceId != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetUserSourceId gets a reference to the given string and assigns it to the UserSourceId field.
+func (o *TaskStartTask) SetUserSourceId(v string) {
+	o.UserSourceId = &v
+}
+
+func (o TaskStartTask) MarshalJSON() ([]byte, error) {
+	toSerialize := map[string]interface{}{}
+	if o.UserApiKey != nil {
+		toSerialize["user_api_key"] = o.UserApiKey
+	}
+	if o.UserId != nil {
+		toSerialize["user_id"] = o.UserId
+	}
+	if o.UserSourceId != nil {
+		toSerialize["user_source_id"] = o.UserSourceId
+	}
+	return json.Marshal(toSerialize)
+}
+
+type NullableTaskStartTask struct {
+	value *TaskStartTask
+	isSet bool
+}
+
+func (v NullableTaskStartTask) Get() *TaskStartTask {
+	return v.value
+}
+
+func (v *NullableTaskStartTask) Set(val *TaskStartTask) {
+	v.value = val
+	v.isSet = true
+}
+
+func (v NullableTaskStartTask) IsSet() bool {
+	return v.isSet
+}
+
+func (v *NullableTaskStartTask) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+func NewNullableTaskStartTask(val *TaskStartTask) *NullableTaskStartTask {
+	return &NullableTaskStartTask{value: val, isSet: true}
+}
+
+func (v NullableTaskStartTask) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+func (v *NullableTaskStartTask) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}
--- a/response.go
+++ b/response.go
@ -3,7 +3,7 @@ Anthrove Orchestrator API

 This service handles the communication between the manager and the plugs

-API version: 0.1-PREVIEW
+API version: 1.0
 Contact: support@anthrove.art
 */

--- a/test/api_plug_test.go
+++ b/test/api_plug_test.go
@ -1,66 +0,0 @@
-/*
-Anthrove Orchestrator API
-
-Testing PlugAPIService
-
-*/
-
-// Code generated by OpenAPI Generator (https://openapi-generator.tech);
-
-package openapi
-
-import (
-	"context"
-	openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client"
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
-	"testing"
-)
-
-func Test_openapi_PlugAPIService(t *testing.T) {
-
-	configuration := openapiclient.NewConfiguration()
-	apiClient := openapiclient.NewAPIClient(configuration)
-
-	t.Run("Test PlugAPIService PlugPlugTypePut", func(t *testing.T) {
-
-		t.Skip("skip test") // remove to run test
-
-		var plugType string
-
-		httpRes, err := apiClient.PlugAPI.PlugPlugTypePut(context.Background(), plugType).Execute()
-
-		require.Nil(t, err)
-		assert.Equal(t, 200, httpRes.StatusCode)
-
-	})
-
-	t.Run("Test PlugAPIService PlugPlugTypeTaskIdDelete", func(t *testing.T) {
-
-		t.Skip("skip test") // remove to run test
-
-		var plugType string
-		var taskId string
-
-		httpRes, err := apiClient.PlugAPI.PlugPlugTypeTaskIdDelete(context.Background(), plugType, taskId).Execute()
-
-		require.Nil(t, err)
-		assert.Equal(t, 200, httpRes.StatusCode)
-
-	})
-
-	t.Run("Test PlugAPIService PlugPlugTypeTaskIdGet", func(t *testing.T) {
-
-		t.Skip("skip test") // remove to run test
-
-		var plugType string
-		var taskId string
-
-		httpRes, err := apiClient.PlugAPI.PlugPlugTypeTaskIdGet(context.Background(), plugType, taskId).Execute()
-
-		require.Nil(t, err)
-		assert.Equal(t, 200, httpRes.StatusCode)
-
-	})
-
-}
--- a/test/api_user_test.go
+++ b/test/api_user_test.go
@ -1,38 +0,0 @@
-/*
-Anthrove Orchestrator API
-
-Testing UserAPIService
-
-*/
-
-// Code generated by OpenAPI Generator (https://openapi-generator.tech);
-
-package openapi
-
-import (
-	"context"
-	openapiclient "git.anthrove.art/Anthrove/orchestrator-swagger-go-client"
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
-	"testing"
-)
-
-func Test_openapi_UserAPIService(t *testing.T) {
-
-	configuration := openapiclient.NewConfiguration()
-	apiClient := openapiclient.NewAPIClient(configuration)
-
-	t.Run("Test UserAPIService UserUserIdPut", func(t *testing.T) {
-
-		t.Skip("skip test") // remove to run test
-
-		var userId string
-
-		httpRes, err := apiClient.UserAPI.UserUserIdPut(context.Background(), userId).Execute()
-
-		require.Nil(t, err)
-		assert.Equal(t, 200, httpRes.StatusCode)
-
-	})
-
-}
--- a/utils.go
+++ b/utils.go
@ -3,7 +3,7 @@ Anthrove Orchestrator API

 This service handles the communication between the manager and the plugs

-API version: 0.1-PREVIEW
+API version: 1.0
 Contact: support@anthrove.art
 */

@ -13,7 +13,6 @@ package openapi

 import (
 	"encoding/json"
-	"reflect"
 	"time"
 )

@ -328,21 +327,3 @@ func (v *NullableTime) UnmarshalJSON(src []byte) error {
 	v.isSet = true
 	return json.Unmarshal(src, &v.value)
 }
-
-// IsNil checks if an input is nil
-func IsNil(i interface{}) bool {
-	if i == nil {
-		return true
-	}
-	switch reflect.TypeOf(i).Kind() {
-	case reflect.Chan, reflect.Func, reflect.Map, reflect.Ptr, reflect.UnsafePointer, reflect.Interface, reflect.Slice:
-		return reflect.ValueOf(i).IsNil()
-	case reflect.Array:
-		return reflect.ValueOf(i).IsZero()
-	}
-	return false
-}
-
-type MappedNullable interface {
-	ToMap() (map[string]interface{}, error)
-}
Author	SHA1	Message	Date
SoXX	9f87c9eebb	feat(version): update to orchestrator version v1.1.0	2024-09-04 20:49:07 +02:00
SoXX	6a34afab9b	feat(version): updated gomod	2024-09-01 19:16:10 +02:00
SoXX	699e8407ec	feat(version): updated for latest release of the Orchestrator	2024-09-01 19:15:48 +02:00
SoXX	bb85c18c6f	fix(version): added /v1	2024-09-01 18:53:07 +02:00
SoXX	f35a816edc	feat(version): updated for latest release of the OOrchestrator	2024-09-01 18:50:40 +02:00
 @ -1 +1 @@
 .2.0
 .2.0