fix: access control soc

ethersphere · Nov 12, 2024 · f19a6a3 · f19a6a3
1 parent 9785a3e
commit f19a6a3
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/pkg/api/accesscontrol_test.go b/pkg/api/accesscontrol_test.go
@@ -100,6 +100,7 @@ func TestAccessLogicEachEndpointWithAct(t *testing.T) {
 		resp        struct {
 			Reference swarm.Address `json:"reference"`
 		}
+		direct bool
 	}{
 		{
 			name:        "bzz",
@@ -159,6 +160,7 @@ func TestAccessLogicEachEndpointWithAct(t *testing.T) {
 			data:        bytes.NewReader(sch.WrappedChunk.Data()),
 			expdata:     sch.Chunk().Data(),
 			contenttype: "binary/octet-stream",
+			direct:      true,
 		},
 	}
 
@@ -183,13 +185,24 @@ func TestAccessLogicEachEndpointWithAct(t *testing.T) {
 			upTestOpts = append(upTestOpts, jsonhttptest.WithRequestHeader(api.SwarmCollectionHeader, "True"))
 		}
 		t.Run(v.name, func(t *testing.T) {
-			client, _, _, _ := newTestServer(t, testServerOptions{
+			client, _, _, chanStore := newTestServer(t, testServerOptions{
 				Storer:        storerMock,
 				Logger:        logger,
 				Post:          mockpost.New(mockpost.WithAcceptAll()),
 				PublicKey:     pk.PublicKey,
 				AccessControl: mockac.New(),
+				DirectUpload:  v.direct,
 			})
+
+			if chanStore != nil {
+				chanStore.Subscribe(func(chunk swarm.Chunk) {
+					err := storerMock.Put(context.Background(), chunk)
+					if err != nil {
+						t.Fatal(err)
+					}
+				})
+			}
+
 			header := jsonhttptest.Request(t, client, http.MethodPost, v.upurl, http.StatusCreated,
 				upTestOpts...,
 			)