Change owned_vehicles to accessible_vehicles, return both user vehicl…

…es and vehicles with privilege and write tests

graph/schema.graphqls

@@ -59,7 +59,7 @@ type Privilege {
 }
 
 type Query {
-  ownedVehicles(
+  accessibleVehicles(
     address: Address!
     first: Int
     after: String

internal/repositories/owned_vehicles.go → internal/repositories/accessible_vehicles.go

@@ -77,21 +77,7 @@ func (v *VehiclesRepo) createVehiclesResponse(totalCount int64, vehicles models.
 	return res
 }
 
-func (v *VehiclesRepo) GetOwnedVehicles(ctx context.Context, addr common.Address, first *int, after *string) (*gmodel.VehicleConnection, error) {
-	totalCount, err := models.Vehicles(
-		models.VehicleWhere.OwnerAddress.EQ(addr.Bytes()),
-	).Count(ctx, v.pdb.DBS().Reader)
-	if err != nil {
-		return nil, err
-	}
-
-	if totalCount == 0 {
-		return &gmodel.VehicleConnection{
-			TotalCount: 0,
-			Edges:      []*gmodel.VehicleEdge{},
-		}, nil
-	}
-
+func (v *VehiclesRepo) GetAccessibleVehicles(ctx context.Context, addr common.Address, first *int, after *string) (*gmodel.VehicleConnection, error) {
 	limit := defaultPageSize
 	if first != nil {
 		limit = *first
@@ -100,12 +86,16 @@ func (v *VehiclesRepo) GetOwnedVehicles(ctx context.Context, addr common.Address
 		}
 	}
 
+	vAlias := "identity_api." + models.TableNames.Vehicles
+	pAlias := "identity_api." + models.TableNames.Privileges
 	queryMods := []qm.QueryMod{
-		models.VehicleWhere.OwnerAddress.EQ(addr.Bytes()),
+		qm.Select(vAlias + ".*"),
+		qm.LeftOuterJoin(
+			"identity_api." + models.TableNames.Privileges + " ON " + vAlias + ".id = " + pAlias + "." + models.PrivilegeColumns.TokenID,
+		),
+		qm.Or2(models.VehicleWhere.OwnerAddress.EQ(addr.Bytes())),
+		qm.Or2(models.PrivilegeWhere.GrantedToAddress.EQ(addr.Bytes())),
 		// Use limit + 1 here to check if there's a next page.
-		qm.Limit(limit + 1),
-		qm.OrderBy(models.VehicleColumns.ID + " DESC"),
-		qm.Load(models.VehicleRels.TokenPrivileges),
 	}
 
 	if after != nil {
@@ -121,6 +111,23 @@ func (v *VehiclesRepo) GetOwnedVehicles(ctx context.Context, addr common.Address
 		queryMods = append(queryMods, models.VehicleWhere.ID.LT(lastCursorVal))
 	}
 
+	totalCount, err := models.Vehicles(queryMods...).Count(ctx, v.pdb.DBS().Reader)
+	if err != nil {
+		return nil, err
+	}
+
+	if totalCount == 0 {
+		return &gmodel.VehicleConnection{
+			TotalCount: 0,
+			Edges:      []*gmodel.VehicleEdge{},
+		}, nil
+	}
+
+	queryMods = append(queryMods,
+		qm.Limit(limit+1),
+		qm.OrderBy(models.VehicleColumns.ID+" DESC"),
+		qm.Load(models.VehicleRels.TokenPrivileges))
+
 	all, err := models.Vehicles(queryMods...).All(ctx, v.pdb.DBS().Reader)
 	if err != nil {
 		return nil, err