Function TestServiceCreateCompatiblePlatforms

client/service_create_test.go:56–102

(t *testing.T)

}

func TestServiceCreateCompatiblePlatforms(t *testing.T) {
	client, err := New(WithMockClient(func(req *http.Request) (*http.Response, error) {
		if strings.HasPrefix(req.URL.Path, defaultAPIPath+"/services/create") {
			var serviceSpec swarm.ServiceSpec

			// check if the /distribution endpoint returned correct output
			err := json.NewDecoder(req.Body).Decode(&serviceSpec)
			if err != nil {
				return nil, err
			}

			assert.Check(t, is.Equal("foobar:1.0@sha256:c0537ff6a5218ef531ece93d4984efc99bbf3f7497c0a7726c88e2bb7584dc96", serviceSpec.TaskTemplate.ContainerSpec.Image))
			assert.Check(t, is.Len(serviceSpec.TaskTemplate.Placement.Platforms, 1))

			p := serviceSpec.TaskTemplate.Placement.Platforms[0]
			return mockJSONResponse(http.StatusOK, nil, swarm.ServiceCreateResponse{
				ID: "service_" + p.OS + "_" + p.Architecture,
			})(req)
		} else if strings.HasPrefix(req.URL.Path, defaultAPIPath+"/distribution/") {
			return mockJSONResponse(http.StatusOK, nil, registrytypes.DistributionInspect{
				Descriptor: ocispec.Descriptor{
					Digest: "sha256:c0537ff6a5218ef531ece93d4984efc99bbf3f7497c0a7726c88e2bb7584dc96",
				},
				Platforms: []ocispec.Platform{
					{
						Architecture: "amd64",
						OS:           "linux",
					},
				},
			})(req)
		} else {
			return nil, fmt.Errorf("unexpected URL '%s'", req.URL.Path)
		}
	}))
	assert.NilError(t, err)

	r, err := client.ServiceCreate(t.Context(), ServiceCreateOptions{
		Spec: swarm.ServiceSpec{
			TaskTemplate: swarm.TaskSpec{
				ContainerSpec: &swarm.ContainerSpec{Image: "foobar:1.0"},
			},
		},
		QueryRegistry: true,
	})
	assert.NilError(t, err)
	assert.Check(t, is.Equal("service_linux_amd64", r.ID))
}

func TestServiceCreateDigestPinning(t *testing.T) {
	dgst := "sha256:c0537ff6a5218ef531ece93d4984efc99bbf3f7497c0a7726c88e2bb7584dc96"