feat: user photo upload and locatable flag [PPT-2038]

migration/db/migrations/202506061335000_alter_uploads_user_photo_locatable.sql

@@ -0,0 +1,29 @@
+-- +micrate Up
+-- SQL in section 'Up' is executed when this migration is applied
+
+-- 1. Add `locatable` with default TRUE and NOT NULL in one step
+-- 2. Add `photo_upload_id` with an inline FK that sets null on delete
+ALTER TABLE "user"
+  ADD COLUMN locatable BOOLEAN NOT NULL DEFAULT true,
+  ADD COLUMN photo_upload_id TEXT REFERENCES uploads(id) ON DELETE SET NULL;
+
+-- 3. Add `tags` to `uploads` as a non-null TEXT[] with an empty‐array default
+ALTER TABLE uploads
+  ADD COLUMN tags TEXT[] NOT NULL DEFAULT '{}';
+
+CREATE INDEX idx_uploads_tags
+  ON uploads
+  USING GIN (tags);
+
+-- +micrate Down
+-- SQL section 'Down' is executed when this migration is rolled back
+
+-- 1. Drop `photo_upload_id` (this also removes the FK constraint automatically)
+-- 2. Drop `locatable`
+ALTER TABLE "user"
+  DROP COLUMN photo_upload_id,
+  DROP COLUMN locatable;
+
+-- 3. Drop `tags`
+ALTER TABLE uploads
+  DROP COLUMN tags;

shard.yml

@@ -53,6 +53,10 @@ dependencies:
   cron_parser:
     github: kostya/cron_parser
 
+  # Upload signer
+  upload-signer:
+    github: spider-gazelle/upload-signer
+
 development_dependencies:
   ameba:
     github: crystal-ameba/ameba

src/placeos-models/upload.cr

@@ -1,4 +1,5 @@
 require "json"
+require "upload-signer"
 
 require "./base/model"
 require "./storage"
@@ -34,6 +35,10 @@ module PlaceOS::Model
     attribute part_data : Hash(String, JSON::Any) = {} of String => JSON::Any
     attribute upload_complete : Bool = false
 
+    # so we can tag which system the upload belongs to
+    # allowing us to filter for relevancy
+    attribute tags : Array(String) = -> { [] of String }
+
     belongs_to Storage
     belongs_to User, foreign_key: "uploaded_by", association_name: "user"
 
@@ -58,5 +63,15 @@ module PlaceOS::Model
     def part_data_changed(flag = true)
       @part_data_changed = flag
     end
+
+    before_destroy :delete_data
+
+    protected def delete_data
+      cloud_fs = self.storage rescue nil
+      return unless cloud_fs
+
+      signer = UploadSigner.signer(UploadSigner::StorageType.from_value(cloud_fs.storage_type.value), cloud_fs.access_key, cloud_fs.decrypt_secret, cloud_fs.region, endpoint: cloud_fs.endpoint)
+      signer.delete_file(cloud_fs.bucket_name, self.object_key, self.resumable_id)
+    end
   end
 end

src/placeos-models/user.cr

@@ -66,6 +66,7 @@ module PlaceOS::Model
 
     attribute sys_admin : Bool = false, mass_assignment: false
     attribute support : Bool = false, mass_assignment: false
+    attribute locatable : Bool = true
 
     attribute login_count : Int64 = 0
     attribute last_login : Time? = nil, converter: Time::EpochConverterOptional, type: "integer", format: "Int64"
@@ -77,6 +78,7 @@ module PlaceOS::Model
     ################################################################################################
 
     belongs_to Authority
+    belongs_to Upload, foreign_key: :photo_upload_id
 
     has_many(
       child_class: UserAuthLookup,
@@ -291,7 +293,7 @@ module PlaceOS::Model
       :email_digest, :email, :nickname, :name, :first_name, :last_name, :groups,
       :country, :building, :image, :created_at, :authority_id, :deleted,
       :department, :preferred_language, :staff_id, :phone, :work_preferences,
-      :work_overrides, :login_count, :last_login,
+      :work_overrides, :login_count, :last_login, :photo_upload_id, :locatable,
     ]
 
     {% begin %}