add publish subscribe

Signed-off-by: Arvindh <[email protected]>
absmach · Nov 4, 2024 · 8e93849 · 8e93849
1 parent 749861b
commit 8e93849
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 11 deletions.
diff --git a/channels/mocks/service.go b/channels/mocks/service.go
diff --git a/channels/private/service.go b/channels/private/service.go
@@ -46,6 +46,7 @@ func (svc service) Authorize(ctx context.Context, req channels.AuthzReq) error {
 		if err := svc.repo.ThingAuthorize(ctx, channels.Connection{
 			ChannelID: req.ChannelID,
 			ThingID:   req.ClientID,
+			Type:      req.Type,
 		}); err != nil {
 			return errors.Wrap(svcerr.ErrAuthorization, err)
 		}

diff --git a/things/api/grpc/endpoint.go b/things/api/grpc/endpoint.go
@@ -75,6 +75,7 @@ func addConnectionsEndpoint(svc pThings.Service) endpoint.Endpoint {
 				ThingID:   c.thingID,
 				ChannelID: c.channelID,
 				DomainID:  c.domainID,
+				Type:      c.connType,
 			})
 		}
 		if err := svc.AddConnections(ctx, conns); err != nil {
@@ -98,6 +99,7 @@ func removeConnectionsEndpoint(svc pThings.Service) endpoint.Endpoint {
 				ThingID:   c.thingID,
 				ChannelID: c.channelID,
 				DomainID:  c.domainID,
+				Type:      c.connType,
 			})
 		}
 		if err := svc.RemoveConnections(ctx, conns); err != nil {

diff --git a/things/postgres/clients.go b/things/postgres/clients.go
@@ -200,7 +200,6 @@ func (repo *clientsRepo) AddConnections(ctx context.Context, conns []things.Conn
 
 	dbConns := toDBConnections(conns)
 
-	fmt.Printf("%+v\n", dbConns)
 	q := `INSERT INTO connections (channel_id, domain_id, thing_id, type)
 			VALUES (:channel_id, :domain_id, :thing_id, :type);`