feat: list devices based on permissions

internal/migrations/schema.sql

@@ -67,8 +67,7 @@ CREATE TABLE dahua_permissions (
   user_id INTEGER,
   group_id INTEGER,
   device_id INTEGER NOT NULL,
-  read BOOLEAN NOT NULL,
-  write BOOLEAN NOT NULL,
+  level INTEGER NOT NULL,
   UNIQUE (user_id, device_id),
   UNIQUE (group_id, device_id),
   FOREIGN KEY (user_id) REFERENCES users (id) ON UPDATE CASCADE ON DELETE CASCADE,

internal/migrations/sql/20240121020400_initial.sql

@@ -0,0 +1,25 @@
+-- +goose Up
+-- disable the enforcement of foreign-keys constraints
+PRAGMA foreign_keys = off;
+-- create "new_dahua_permissions" table
+CREATE TABLE `new_dahua_permissions` (`user_id` integer NULL, `group_id` integer NULL, `device_id` integer NOT NULL, `level` integer NOT NULL, CONSTRAINT `0` FOREIGN KEY (`device_id`) REFERENCES `dahua_devices` (`id`) ON UPDATE CASCADE ON DELETE CASCADE, CONSTRAINT `1` FOREIGN KEY (`group_id`) REFERENCES `groups` (`id`) ON UPDATE CASCADE ON DELETE CASCADE, CONSTRAINT `2` FOREIGN KEY (`user_id`) REFERENCES `users` (`id`) ON UPDATE CASCADE ON DELETE CASCADE);
+-- copy rows from old table "dahua_permissions" to new temporary table "new_dahua_permissions"
+INSERT INTO `new_dahua_permissions` (`user_id`, `group_id`, `device_id`) SELECT `user_id`, `group_id`, `device_id` FROM `dahua_permissions`;
+-- drop "dahua_permissions" table after copying rows
+DROP TABLE `dahua_permissions`;
+-- rename temporary table "new_dahua_permissions" to "dahua_permissions"
+ALTER TABLE `new_dahua_permissions` RENAME TO `dahua_permissions`;
+-- create index "dahua_permissions_user_id_device_id" to table: "dahua_permissions"
+CREATE UNIQUE INDEX `dahua_permissions_user_id_device_id` ON `dahua_permissions` (`user_id`, `device_id`);
+-- create index "dahua_permissions_group_id_device_id" to table: "dahua_permissions"
+CREATE UNIQUE INDEX `dahua_permissions_group_id_device_id` ON `dahua_permissions` (`group_id`, `device_id`);
+-- enable back the enforcement of foreign-keys constraints
+PRAGMA foreign_keys = on;
+
+-- +goose Down
+-- reverse: create index "dahua_permissions_group_id_device_id" to table: "dahua_permissions"
+DROP INDEX `dahua_permissions_group_id_device_id`;
+-- reverse: create index "dahua_permissions_user_id_device_id" to table: "dahua_permissions"
+DROP INDEX `dahua_permissions_user_id_device_id`;
+-- reverse: create "new_dahua_permissions" table
+DROP TABLE `new_dahua_permissions`;

internal/migrations/sql/atlas.sum

@@ -1,7 +1,8 @@
-h1:o8JBZ3wyYZ6BcnXbnExh/xAzDZodh/60NdLuOgOAeUY=
+h1:OALKVgKef9vRTB38+EIZnMsM75/+feypay54rrqeLOA=
 20240114082916_initial.sql h1:6T2vRM1rfcsNzTh9YR0sXB8U+T3GZ6PiJcZc23WvXl8=
 20240117044510_initial.sql h1:91cIrQzdHSR9DIvMzRnuBlbTptlf877EieEYXT3wRaU=
 20240117054837_initial.sql h1:Xw8Z7y27y9fCrv5VnGjb5W1XwtHClBgiGr92AlRL9pM=
 20240117055231_initial.sql h1:/CD25FfvoH5yUaDdzIMnZ0HOUV1LJm9jxpKoP+mKWSU=
 20240118025315_initial.sql h1:0NT8HEKbPi2uMxuMv0SYyyhg821qZ+SRzGoH//8ytrA=
 20240120004552_initial.sql h1:PG61nxPoo4MSEgZCy7Vojc+txW8GOS4tv57rSiswzwE=
+20240121020400_initial.sql h1:PVapHcXZ7bgNOp0W6ZkT/VMJnjk2NUUVWOtt6Ktt7ms=

internal/models/dahua.go

@@ -72,6 +72,7 @@ func (lhs DahuaConn) EQ(rhs DahuaConn) bool {
 type DahuaDeviceConn struct {
 	DahuaDevice
 	DahuaConn
+	Level DahuaPermissionLevel
 }
 
 type DahuaFeature int
@@ -227,3 +228,24 @@ type DahuaStorageDestination struct {
 	Password        string
 	RemoteDirectory string
 }
+
+type DahuaPermissionLevel int
+
+const (
+	DahuaPermissionLevelUser DahuaPermissionLevel = iota
+	DahuaPermissionLevelOperator
+	DahuaPermissionLevelAdmin
+)
+
+func (l DahuaPermissionLevel) String() string {
+	switch l {
+	case DahuaPermissionLevelUser:
+		return "user"
+	case DahuaPermissionLevelOperator:
+		return "operator"
+	case DahuaPermissionLevelAdmin:
+		return "admin"
+	default:
+		return "unknown"
+	}
+}

internal/repo/convert.go

@@ -26,6 +26,7 @@ func (c ListDahuaDeviceByIDsRow) Convert() models.DahuaDeviceConn {
 			Feature:  c.Feature,
 			Seed:     int(c.Seed),
 		},
+		Level: models.DahuaPermissionLevelAdmin,
 	}
 }
 
@@ -51,6 +52,7 @@ func (c GetDahuaDeviceRow) Convert() models.DahuaDeviceConn {
 			Feature:  c.Feature,
 			Seed:     int(c.Seed),
 		},
+		Level: models.DahuaPermissionLevelAdmin,
 	}
 }
 
@@ -76,6 +78,7 @@ func (c GetDahuaDeviceByIPRow) Convert() models.DahuaDeviceConn {
 			Feature:  c.Feature,
 			Seed:     int(c.Seed),
 		},
+		Level: models.DahuaPermissionLevelAdmin,
 	}
 }
 
@@ -101,6 +104,7 @@ func (c ListDahuaDeviceRow) Convert() models.DahuaDeviceConn {
 			Feature:  c.Feature,
 			Seed:     int(c.Seed),
 		},
+		Level: models.DahuaPermissionLevelAdmin,
 	}
 }
 
@@ -126,6 +130,33 @@ func (c ListDahuaDeviceByFeatureRow) Convert() models.DahuaDeviceConn {
 			Feature:  c.Feature,
 			Seed:     int(c.Seed),
 		},
+		Level: models.DahuaPermissionLevelAdmin,
+	}
+}
+
+func (c ListDahuaDeviceForUserRow) Convert() models.DahuaDeviceConn {
+	return models.DahuaDeviceConn{
+		DahuaDevice: models.DahuaDevice{
+			ID:        c.ID,
+			Url:       c.Url.URL,
+			Username:  c.Username,
+			Password:  c.Password,
+			Location:  c.Location.Location,
+			Name:      c.Name,
+			CreatedAt: c.CreatedAt.Time,
+			UpdatedAt: c.UpdatedAt.Time,
+			Feature:   c.Feature,
+		},
+		DahuaConn: models.DahuaConn{
+			ID:       c.ID,
+			Url:      c.Url.URL,
+			Username: c.Username,
+			Password: c.Password,
+			Location: c.Location.Location,
+			Feature:  c.Feature,
+			Seed:     int(c.Seed),
+		},
+		Level: c.Level,
 	}
 }
 

internal/repo/sqlc_query.sql

@@ -114,8 +114,11 @@ WHERE
 -- name: ListGroupForUser :many
 SELECT
   g.*
-FROM groups AS g LEFT JOIN group_users AS gu ON gu.group_id = g.id
-WHERE gu.user_id = ?;
+FROM
+  groups AS g
+  LEFT JOIN group_users AS gu ON gu.group_id = g.id
+WHERE
+  gu.user_id = ?;
 
 -- name: createDahuaDevice :one
 INSERT INTO
@@ -205,6 +208,31 @@ FROM
 WHERE
   id IN (sqlc.slice ('ids'));
 
+-- name: ListDahuaDeviceForUser :many
+SELECT
+  d.*,
+  coalesce(s.seed, d.id) AS seed,
+  coalesce(p.level, 2)
+FROM
+  dahua_devices as d
+  LEFT JOIN dahua_seeds AS s ON s.device_id = d.id
+  LEFT JOIN dahua_permissions AS p ON p.device_id = d.id
+WHERE
+  true = sqlc.arg ('admin')
+  OR p.user_id = sqlc.arg ('user_id')
+  OR p.group_id IN (
+    SELECT
+      group_id
+    FROM
+      group_users
+    WHERE
+      user_id = sqlc.arg ('user_id')
+  )
+GROUP BY
+  d.id
+ORDER BY
+  p.level DESC;
+
 -- name: listDahuaDeviceByFeature :many
 SELECT
   dahua_devices.*,

internal/rpcserver/page.go

@@ -2,8 +2,10 @@ package rpcserver
 
 import (
 	"context"
+	"fmt"
 	"time"
 
+	"github.com/ItsNotGoodName/ipcmanview/internal/core"
 	"github.com/ItsNotGoodName/ipcmanview/internal/repo"
 	"github.com/ItsNotGoodName/ipcmanview/internal/types"
 	"github.com/ItsNotGoodName/ipcmanview/rpc"
@@ -14,6 +16,26 @@ type Page struct {
 	DB repo.DB
 }
 
+func (p *Page) Home(ctx context.Context, req *rpc.PageHomeReq) (*rpc.PageHomeResp, error) {
+	authSession := useAuthSession(ctx)
+
+	dbDevices, err := p.DB.ListDahuaDeviceForUser(ctx, repo.ListDahuaDeviceForUserParams{
+		Admin:  authSession.Admin,
+		UserID: core.Int64ToNullInt64(authSession.UserID),
+	})
+	if err != nil {
+		return nil, NewError(err).Internal()
+	}
+
+	for _, lddfur := range dbDevices {
+		fmt.Println(lddfur.ID, lddfur.Level)
+	}
+
+	return &rpc.PageHomeResp{
+		DeviceCount: int64(len(dbDevices)),
+	}, nil
+}
+
 func (p *Page) Profile(ctx context.Context, req *rpc.PageProfileReq) (*rpc.PageProfileResp, error) {
 	authSession := useAuthSession(ctx)
 

internal/web/src/pages/Home.data.ts

@@ -0,0 +1,8 @@
+import { cache } from "@solidjs/router";
+import { useClient } from "~/providers/client";
+
+export const getHome = cache(() => useClient().page.home({}).then((req) => req.response), "getHome")
+
+export function loadHome() {
+  void getHome()
+}