-
Notifications
You must be signed in to change notification settings - Fork 1
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: cdb 2663 ipfs queue service #30
Conversation
CDB-2663 IPFS Queue + Service
DescriptionQueue to receive IPFS job messages IPFS service that reads off the IPFS queue and completes the job The only possible job will be publishing QUERY responses |
8f18e55
to
8b44edb
Compare
common/ipfs/api.go
Outdated
return nil | ||
} | ||
|
||
func (i *IpfsApi) processIpfsTask(ctx context.Context, task any) (any, error) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
func (i *IpfsApi) processIpfsTask(ctx context.Context, task any) (any, error) { | |
func (i *IpfsApi) processIpfsTask(ctx context.Context, task any) error { | |
if pubsubPublishTask, ok := task.(models.PubSubPublishTask); ok { | |
return i.pubsubPublish(ctx, pubsubPublishTask) | |
} | |
return fmt.Errorf("unknown ipfs task received %v", task) | |
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚀🚀🚀
confirmed that the pubsub response messages published via this service actually works!