Integration of the orchestrator API and authentication based on payload signature

packages/api/src/execution-lcd.ts

@@ -1,4 +1,5 @@
 import LCDClient from './util/lcd'
+import { IStruct } from './struct'
 
 export enum Status {
   Unknown = 0,
@@ -15,8 +16,8 @@ export type IExecution = {
   status: Status;
   instanceHash: string;
   taskKey: string;
-  inputs?: any;
-  outputs?: any;
+  inputs?: IStruct[];
+  outputs?: IStruct[];
   error?: (string | null);
   tags?: (string[] | null);
   processHash?: (string | null);
@@ -33,7 +34,7 @@ export type IExecution = {
 
 export default class Execution extends LCDClient {
 
-  async get(hash: string): Promise<IExecution> { 
+  async get(hash: string): Promise<IExecution> {
     return (await this.query(`/execution/get/${hash}`)).result
   }
 

packages/api/src/process-lcd.ts

@@ -1,6 +1,7 @@
 import * as ProcessType from './typedef/process'
 import LCDClient from './util/lcd'
 import { IMsg } from './transaction'
+import { IValueNullType, IValueStringType, IValueNumberType, IValueBoolType } from './struct'
 
 export type IResult = {
   instanceHash: string;
@@ -118,34 +119,10 @@ export const Predicate = {
   CONTAINS: FilterPredicate.CONTAINS
 }
 
-export type IFilterValueNullType = {
-  type: 'mesg.types.Value_NullValue';
-  value: {
-    null?: 0
-  }
-}
-
-export type IFilterValueStringType = {
-  type: 'mesg.types.Value_StringValue';
-  value: {
-    string_value: string;
-  }
-}
-
-export type IFilterValueNumberType = {
-  type: 'mesg.types.Value_NumberValue';
-  value: {
-    number_value: number;
-  }
-}
-
-export type IFilterValueBoolType = {
-  type: 'mesg.types.Value_BoolValue';
-  value: {
-    bool_value: boolean;
-  }
-}
-
+export type IFilterValueNullType = IValueNullType
+export type IFilterValueStringType = IValueStringType
+export type IFilterValueNumberType = IValueNumberType
+export type IFilterValueBoolType = IValueBoolType
 
 export type IFilterCondition = {
   ref: {

packages/api/src/struct.ts

@@ -0,0 +1,104 @@
+export type IValueNullType = {
+  type: 'mesg.types.Value_NullValue';
+  value: {
+    null?: 0
+  }
+}
+
+export type IValueStringType = {
+  type: 'mesg.types.Value_StringValue';
+  value: {
+    string_value: string;
+  }
+}
+
+export type IValueNumberType = {
+  type: 'mesg.types.Value_NumberValue';
+  value: {
+    number_value: number;
+  }
+}
+
+export type IValueBoolType = {
+  type: 'mesg.types.Value_BoolValue';
+  value: {
+    bool_value: boolean;
+  }
+}
+
+export type IValueListType = {
+  type: "mesg.types.Value_ListValue",
+  value: {
+    list_value: {
+      values: IValue[]
+    }
+  }
+}
+
+export type IValueMapType = {
+  type: "mesg.types.Value_StructValue",
+  value: {
+    struct_value: IStruct[]
+  }
+}
+
+export type IValue = {
+  Kind: IValueBoolType | IValueNumberType | IValueStringType | IValueNullType | IValueListType | IValueMapType
+}
+
+export type IStruct = {
+  Key: string
+  Value: IValue
+}
+
+export const toValue = (value: any): IValueBoolType | IValueNumberType | IValueStringType | IValueNullType | IValueListType | IValueMapType => {
+  switch (Object.prototype.toString.call(value)) {
+    case '[object Null]':
+    case '[object Undefined]':
+      return {
+        type: "mesg.types.Value_NullValue", value: {}
+      } as IValueNullType
+    case '[object Object]':
+      return {
+        type: "mesg.types.Value_StructValue",
+        value: {
+          struct_value: toStruct(value)
+        }
+      } as IValueMapType
+    case '[object Array]':
+      return {
+        type: "mesg.types.Value_ListValue",
+        value: {
+          list_value: {
+            values: value.map((x: any) => ({ Kind: toValue(x) }))
+          }
+        }
+      } as IValueListType
+    case '[object Number]':
+      return {
+        type: "mesg.types.Value_NumberValue", value: { number_value: value }
+      } as IValueNumberType
+    case '[object Boolean]':
+      return {
+        type: "mesg.types.Value_BoolValue", value: { bool_value: value }
+      } as IValueBoolType
+    case '[object String]':
+      return {
+        type: "mesg.types.Value_StringValue", value: { string_value: value }
+      } as IValueStringType
+    default:
+      throw new Error('not supported')
+  }
+}
+
+export const toStruct = (object: { [key: string]: any }): IStruct[] => {
+  return Object.keys(object).reduce((prev, x) => [
+    ...prev,
+    {
+      Key: x,
+      Value: {
+        Kind: toValue(object[x])
+      }
+    }
+  ], [] as IStruct[])
+}

packages/api/src/transaction.ts

@@ -44,7 +44,7 @@ export default class Transaction {
   private _stdTx: IStdTx
   public raw: ITx
 
-  static sign(message: string, ecpairPriv: Buffer): any {
+  static sign(message: string, ecpairPriv: Buffer) {
     const hash = createHash('sha256')
       .update(message)
       .digest('hex')