Skip to content

Commit

Permalink
Merge pull request #1521 from mesg-foundation/fix/runner-sdk
Browse files Browse the repository at this point in the history
Fix runner sdk
  • Loading branch information
antho1404 authored Nov 22, 2019
2 parents 6df2444 + 5c8686f commit e6ae30f
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion sdk/runner/sdk.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package runnersdk

import (
"errors"
"fmt"

cosmostypes "github.com/cosmos/cosmos-sdk/types"
"github.com/mesg-foundation/engine/container"
Expand Down Expand Up @@ -79,6 +80,10 @@ func (s *SDK) Create(req *api.CreateRunnerRequest, accountName, accountPassword
InstanceHash: instanceHash,
})

if runExisting, _ := s.Get(expRunnerHash); runExisting != nil {
return nil, fmt.Errorf("runner %q already exists", runExisting.Hash)
}

// start the container
imageHash, err := build(s.container, srv, s.ipfsEndpoint)
if err != nil {
Expand Down Expand Up @@ -182,7 +187,7 @@ func (s *SDK) List(f *Filter) ([]*runner.Runner, error) {
ret := make([]*runner.Runner, 0)
for _, runner := range runners {
if (f.Address == "" || runner.Address == f.Address) &&
(f.InstanceHash.IsZero() || runner.Hash.Equal(f.InstanceHash)) {
(f.InstanceHash.IsZero() || runner.InstanceHash.Equal(f.InstanceHash)) {
ret = append(ret, runner)
}
}
Expand Down

0 comments on commit e6ae30f

Please sign in to comment.