Update to latest substreams version

.github/workflows/golangci-lint.yaml

@@ -2,9 +2,9 @@
 name: Linting
 on:
   push:
-    branches: [ develop* ]
+    branches: [develop*]
   pull_request:
-    branches: [ develop*,main ]
+    branches: [develop*, main]
 
 permissions:
   contents: read
@@ -14,8 +14,8 @@ jobs:
     runs-on: ${{ matrix.os }}
     strategy:
       matrix:
-        go-version: [ 1.21.x ]
-        os: [ ubuntu-latest ]
+        go-version: [1.21.x]
+        os: [ubuntu-latest]
     name: lint
     steps:
       - name: Checkout repo
@@ -32,13 +32,15 @@ jobs:
           repo-token: ${{ secrets.GITHUB_TOKEN }}
 
       - name: Format
-        run: task test:format
+        run: cd api-service && task test:format
 
       - name: Run golangci-lint
         uses: golangci/golangci-lint-action@v4
         with:
           # Required: the version of golangci-lint is required and must be specified without patch version: we always use the latest patch version.
           version: v1.56
+          # Optional: working directory, useful when you have multiple Go modules
+          working-directory: api-service
           # Optional: golangci-lint command line arguments.
           args: --timeout=5m
           # Optional: show only new issues if it's a pull request. The default value is `false`.

proto/substreams/sink/kv/v1/kv.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+package sf.substreams.sink.kv.v1;
+
+option go_package = "github.com/streamingfast/substreams-sink-kv/pb;pbkv";
+
+message KVOperations {
+  repeated KVOperation operations = 1;
+}
+
+message KVOperation {
+  string key = 1;
+  bytes value = 2;
+  uint64 ordinal = 3;
+  enum Type {
+    UNSET = 0;    // Protobuf default should not be used, this is used so that the consume can ensure that the value was actually specified
+    SET = 1;
+    DELETE = 2;
+  }
+  Type type = 4;
+}

proto/substreams/sink/kv/v1/services.proto

@@ -0,0 +1,26 @@
+syntax = "proto3";
+package sf.substreams.sink.kv.v1;
+
+option go_package = "github.com/streamingfast/substreams-sink-kv/pb;pbkv";
+
+
+message Config {
+  int64 start_block = 1;
+  string input_module = 2;
+}
+
+// This defines a KV Sink to be queried with a generic key access interface (Get, GetMany, Scan, Prefix calls).
+message GenericService {
+  Config sink_config = 1;
+}
+
+// This defines configuration to run a WASM query service on top of the KV store being sync'd.
+message WASMQueryService  {
+  Config sink_config = 1;
+
+  // wasm exports: "kv_get_batch", "kv_get", "kv_scan", "kv_prefix"
+  bytes wasm_query_module = 5;
+
+  // Fully qualified Protobuf Service definition name
+  string grpc_service = 2; // sf.mycustom.v1.MyService
+}