Delete database/migrations

database/migrations/20230817172319_init.sql

@@ -1,66 +0,0 @@
--- +goose Up
-create extension if not exists pgcrypto;
-
-create extension if not exists btree_gin;
-
-create schema if not exists teldrive;
-
-create collation if not exists numeric (provider = icu, locale = 'en@colnumeric=yes');
-
--- +goose StatementBegin
-create or replace
-function teldrive.generate_uid(size int) returns text language plpgsql as $$
-declare characters text := 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
-
-bytes bytea := gen_random_bytes(size);
-
-l int := length(characters);
-
-i int := 0;
-
-output text := '';
-
-begin while i < size loop output := output || substr(characters,
-get_byte(bytes,
-i) % l + 1,
-1);
-
-i := i + 1;
-end loop;
-
-return output;
-end;
-
-$$;
--- +goose StatementEnd
-
--- +goose StatementBegin
-create or replace
-function teldrive.get_tsvector(t text) returns tsvector language plpgsql immutable as $$
-declare res tsvector := to_tsvector(regexp_replace(t,
-'[^A-Za-z0-9 ]',
-' ',
-'g'));
-
-begin return res;
-end;
-
-$$;
--- +goose StatementEnd
-
--- +goose StatementBegin
-create or replace
-function teldrive.get_tsquery(t text) returns tsquery language plpgsql immutable as $$
-declare res tsquery = concat(
-plainto_tsquery(regexp_replace(t,
-'[^A-Za-z0-9 ]',
-' ',
-'g')),
-':*'
-)::tsquery;
-
-begin return res;
-end;
-
-$$;
--- +goose StatementEnd

database/migrations/20230817172325_tables.sql

@@ -1,88 +0,0 @@
--- +goose Up
-create table teldrive.files (
-id text primary key not null default teldrive.generate_uid(16),
-name text not null,
-type text not null,
-mime_type text not null,
-path text null,
-size bigint null,
-starred bool not null,
-depth integer null,
-user_id bigint not null,
-parent_id text null,
-status text default 'active'::text,
-channel_id bigint null,
-parts jsonb null,
-created_at timestamp not null default timezone('utc'::text,
-now()),
-updated_at timestamp not null default timezone('utc'::text,
-now()),
-constraint unique_file unique (name,
-parent_id,user_id)
-);
-
-create table teldrive.uploads (
-	id text not null primary key default teldrive.generate_uid(16),
-	upload_id text not null,
-	name text not null,
-	part_no int4 not null,
-	part_id int4 not null,
-	total_parts int4 not null,
-	channel_id int8 not null,
-	size int8 not null,
-	created_at timestamp null default timezone('utc'::text,
-now())
-);
-
-create table teldrive.users (
-	user_id bigint not null primary key,
-	name text null,
-	user_name text null,
-	is_premium bool not null,
-	tg_session text not null,
-	settings jsonb null,
-	created_at timestamptz not null default timezone('utc'::text,
-now()),
-	updated_at timestamptz not null default timezone('utc'::text,
-now())
-);
-
-create collation if not exists numeric (provider = icu, locale = 'en@colnumeric=yes');
-create index  name_search_idx on
-teldrive.files
-	using gin (teldrive.get_tsvector(name),
-updated_at);
-
-create index  name_numeric_idx on
-teldrive.files(name collate numeric nulls first);
-
-create index  parent_name_numeric_idx on
-teldrive.files (parent_id,
-name collate numeric desc);
-
-create index  path_idx on
-teldrive.files (path);
-
-create index  parent_idx on
-teldrive.files (parent_id);
-
-create index  starred_updated_at_idx on
-teldrive.files (starred,
-updated_at desc);
-
-create index  status_idx on teldrive.files (status);
-
-create index  user_id_idx on teldrive.files (user_id);
-
--- +goose Down
-drop table if exists teldrive.files;
-drop table if exists teldrive.uploads;
-drop table if exists teldrive.users;
-drop index if exists teldrive.name_search_idx;
-drop index if exists teldrive.name_numeric_idx;
-drop index if exists teldrive.parent_name_numeric_idx;
-drop index if exists teldrive.path_idx;
-drop index if exists teldrive.parent_idx;
-drop index if exists teldrive.starred_updated_at_idx;
-drop index if exists teldrive.status_idx;
-drop index if exists teldrive.user_id_idx;

database/migrations/20230817172329_functions.sql

@@ -1,188 +0,0 @@
--- +goose Up
-
--- +goose StatementBegin
-create procedure teldrive.update_size() language plpgsql as $$
-declare rec record;
-
-total_size bigint;
-
-begin
-
-for rec in
-select
-	id
-from
-	files
-where
-	type = 'folder'
-order by
-	depth desc loop total_size := (
-	select
-		sum(size) as total_size
-	from
-		teldrive.files
-	where
-		parent_id = rec.id
-);
-
-update
-	teldrive.files
-set
-	size = total_size
-where
-	id = rec.id;
-end loop;
-end;
-
-$$;
--- +goose StatementEnd
-
-
--- +goose StatementBegin
-create function teldrive.update_folder(folder_id text,
-new_name text default null,
-new_path text default null)
- returns setof teldrive.files
- language plpgsql
-as $$
-declare folder record;
-
-path_items text [];
-
-begin 
-
-if new_path is null then
-select
-	*
-into
-	folder
-from
-	teldrive.files
-where
-	id = folder_id;
-
-path_items := string_to_array(folder.path,
-'/');
-
-path_items [array_length(path_items,
-1)] := new_name;
-
-new_path := array_to_string(path_items,
-'/');
-end if;
-
-update
-	teldrive.files
-set
-	path = new_path,
-	name = new_name
-where
-	id = folder_id;
-
-for folder in
-select
-	*
-from
-	teldrive.files
-where
-	type = 'folder'
-	and parent_id = folder_id loop call teldrive.update_folder(
-	folder.id,
-	folder.name,
-	concat(new_path,
-	'/',
-	folder.name)
-);
-end loop;
-
-return query
-select
-	*
-from
-	teldrive.files
-where
-	id = folder_id;
-end;
-
-$$
-;
--- +goose StatementEnd
-
--- +goose StatementBegin
-create procedure teldrive.delete_files(in file_ids text[],
-in op text default 'bulk')
- language plpgsql
-as $$
-    declare 
-    rec record;
-
-begin
-    if op = 'bulk' then
-    for rec in
-select
-	id,
-	type
-from
-	teldrive.files
-where
-	id = any (file_ids)
-    loop 
-	    if rec.type = 'folder' then
-	    call teldrive.delete_files(array [rec.id],
-	'single');
-
-delete
-from
-	teldrive.files
-where
-	id = rec.id;
-else
-	    update
-	teldrive.files
-set
-	status = 'pending_deletion'
-where
-	id = rec.id;
-end if;
-end loop;
-else
-   
-   for rec in
-select
-	id,
-	type
-from
-	teldrive.files
-where
-	parent_id = file_ids[1]
-    loop 
-	    if rec.type = 'folder' then
-	    call teldrive.delete_files(array [rec.id],
-	'single');
-
-delete
-from
-	teldrive.files
-where
-	id = rec.id;
-else
-	    update
-	teldrive.files
-set
-	status = 'pending_deletion'
-where
-	id = rec.id;
-end if;
-end loop;
-end if;
-end;
-
-$$
-;
--- +goose StatementEnd
-
-
--- +goose Down
-drop procedure if exists teldrive.update_size;
-drop function if exists teldrive.update_folder;
-drop procedure if exists teldrive.delete_files;

database/migrations/20230820014560_create_dirs_from_path.sql

@@ -1,48 +0,0 @@
--- +goose Up
--- +goose StatementBegin
-
-CREATE OR REPLACE FUNCTION teldrive.create_directories(
-    IN tg_id BIGINT,
-    IN long_path TEXT
-) RETURNS SETOF teldrive.files AS $$
-DECLARE
-    path_parts TEXT[];
-    current_directory_id TEXT;
-    new_directory_id TEXT;
-    directory_name TEXT;
-    path_so_far TEXT;
-    depth_dir integer;
-begin
-	
-    path_parts := string_to_array(regexp_replace(long_path, '^/+', ''), '/');
-   
-    path_so_far := '';
-    depth_dir := 0;
-
-    SELECT id  into  current_directory_id FROM teldrive.files WHERE parent_id='root';
-
-
-    FOR directory_name IN SELECT unnest(path_parts) LOOP
-	    path_so_far := CONCAT(path_so_far,'/', directory_name);
-	    depth_dir := depth_dir +1;
-        SELECT id INTO new_directory_id
-        FROM teldrive.files
-        WHERE parent_id = current_directory_id
-        AND "name" = directory_name AND "user_id"=tg_id;
-
-        IF new_directory_id IS NULL THEN
-            INSERT INTO teldrive.files ("name", "type", mime_type, parent_id, "user_id",starred,"depth","path")
-            VALUES (directory_name, 'folder', 'drive/folder', current_directory_id, tg_id,false,depth_dir,path_so_far)
-            RETURNING id INTO new_directory_id;
-        END IF;
-        
-        current_directory_id := new_directory_id;
-    END LOOP;
-
-    RETURN QUERY SELECT * FROM teldrive.files WHERE id = current_directory_id;
-END;
-$$ LANGUAGE plpgsql;
--- +goose StatementEnd
-
--- +goose Down
-DROP FUNCTION IF EXISTS teldrive.create_directories;

database/migrations/20230911113332_alter_table.sql

@@ -1,5 +0,0 @@
--- +goose Up
-
-ALTER TABLE teldrive.files DROP CONSTRAINT IF EXISTS unique_file;
-
-CREATE UNIQUE INDEX unique_file ON teldrive.files (name, parent_id, user_id) WHERE (status= 'active');

database/migrations/20230916012407_alter_user.sql

@@ -1,3 +0,0 @@
--- +goose Up
-
-ALTER TABLE teldrive.users DROP COLUMN settings;

database/migrations/20230916012507_tables.sql

@@ -1,27 +0,0 @@
--- +goose Up
--- +goose StatementBegin
-
-CREATE TABLE teldrive.bots (
-    user_id bigint NOT NULL,
-    token text NOT NULL,
-    bot_user_name text NOT NULL,
-    bot_id bigint NOT NULL,
-    FOREIGN KEY (user_id) REFERENCES teldrive.users(user_id),
-    CONSTRAINT btoken_user_un  UNIQUE (user_id,token)
-);
-
-CREATE TABLE teldrive.channels (
-    channel_id bigint NOT NULL PRIMARY KEY,
-    channel_name text NOT NULL,
-    user_id bigint NOT NULL,
-    selected boolean DEFAULT false,
-    FOREIGN KEY (user_id) REFERENCES teldrive.users(user_id)
-);
-
--- +goose StatementEnd
-
--- +goose Down
--- +goose StatementBegin
-DROP TABLE IF EXISTS teldrive.bots;
-DROP TABLE IF EXISTS teldrive.channels;
--- +goose StatementEnd

database/migrations/20230918234353_account_stats.sql

@@ -1,22 +0,0 @@
--- +goose Up
--- +goose StatementBegin
-CREATE OR REPLACE FUNCTION teldrive.account_stats(
-    IN u_id BIGINT
-)  RETURNS TABLE (total_size BIGINT, total_files BIGINT, ch_id BIGINT,ch_name TEXT ) AS $$
-DECLARE
-    total_size BIGINT;
-    total_files BIGINT;
-    ch_id BIGINT;
-    ch_name TEXT;
-BEGIN
-    SELECT COUNT(*), SUM(size) into total_files,total_size FROM teldrive.files WHERE user_id=u_id AND type= 'file' and status='active';
-    SELECT channel_id ,channel_name into ch_id,ch_name FROM teldrive.channels WHERE selected=TRUE AND user_id=u_id;
-    RETURN QUERY SELECT total_size,total_files,ch_id,ch_name;
-END;
-$$ LANGUAGE plpgsql;
--- +goose StatementEnd
-
--- +goose Down
--- +goose StatementBegin
-DROP FUNCTION IF EXISTS teldrive.account_stats;
--- +goose StatementEnd