Add version meta to produce and publish api

ChainSafe · Jan 24, 2025 · 25bfff0 · 25bfff0
1 parent f49f1df
commit 25bfff0
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 10 deletions.
diff --git a/packages/api/src/beacon/routes/validator.ts b/packages/api/src/beacon/routes/validator.ts
@@ -437,7 +437,7 @@ export type Endpoints = {
     },
     {query: {slot: number}},
     focil.InclusionList,
-    EmptyMeta
+    VersionMeta
   >;
 
   /**
@@ -514,7 +514,7 @@ export type Endpoints = {
   publishInclusionList: Endpoint<
     "POST",
     {signedInclusionList: focil.SignedInclusionList},
-    {body: unknown},
+    {body: unknown; headers: {[MetaHeader.Version]: string}},
     EmptyResponseData,
     EmptyMeta
   >;
@@ -915,7 +915,7 @@ export function getDefinitions(config: ChainForkConfig): RouteDefinitions<Endpoi
       },
       resp: {
         data: ssz.focil.InclusionList,
-        meta: EmptyMetaCodec,
+        meta: VersionCodec,
       },
     },
     getAggregatedAttestation: {
@@ -1063,16 +1063,29 @@ export function getDefinitions(config: ChainForkConfig): RouteDefinitions<Endpoi
       url: "/eth/v1/validator/inclusion_list",
       method: "POST",
       req: {
-        writeReqJson: ({signedInclusionList}) => ({
-          body: ssz.focil.SignedInclusionList.toJson(signedInclusionList),
-        }),
+        writeReqJson: ({signedInclusionList}) => {
+          const fork = config.getForkName(signedInclusionList.message.slot);
+          return {
+            body: ssz.focil.SignedInclusionList.toJson(signedInclusionList),
+            headers: {
+              [MetaHeader.Version]: fork,
+            },
+          };
+        },
         parseReqJson: ({body}) => ({signedInclusionList: ssz.focil.SignedInclusionList.fromJson(body)}),
-        writeReqSsz: ({signedInclusionList}) => ({
-          body: ssz.focil.SignedInclusionList.serialize(signedInclusionList),
-        }),
+        writeReqSsz: ({signedInclusionList}) => {
+          const fork = config.getForkName(signedInclusionList.message.slot);
+          return {
+            body: ssz.focil.SignedInclusionList.serialize(signedInclusionList),
+            headers: {
+              [MetaHeader.Version]: fork,
+            },
+          };
+        },
         parseReqSsz: ({body}) => ({signedInclusionList: ssz.focil.SignedInclusionList.deserialize(body)}),
         schema: {
           body: Schema.Object,
+          headers: {[MetaHeader.Version]: Schema.String},
         },
       },
       resp: EmptyResponseCodec,

diff --git a/packages/api/test/unit/beacon/testData/validator.ts b/packages/api/test/unit/beacon/testData/validator.ts
@@ -113,7 +113,7 @@ export const testData: GenericServerTestCases<Endpoints> = {
   },
   produceInclusionList: {
     args: {slot: 32000},
-    res: {data: ssz.focil.InclusionList.defaultValue()},
+    res: {data: ssz.focil.InclusionList.defaultValue(), meta: {version: ForkName.focil}},
   },
   getAggregatedAttestation: {
     args: {attestationDataRoot: ZERO_HASH, slot: 32000},