Embed migrations

.env.example

@@ -1,21 +0,0 @@
-# AWS S3 Configuration
-# Регион AWS (например: us-east-1, eu-west-1)
-AWS_REGION=us-east-1
-
-# AWS Access Key ID (получить в AWS Console)
-AWS_ACCESS_KEY_ID=your_access_key_id
-
-# AWS Secret Access Key (получить в AWS Console)
-AWS_SECRET_ACCESS_KEY=your_secret_access_key
-
-# Имя S3 bucket для загрузки файлов
-S3_BUCKET_NAME=your_bucket_name
-
-# Кастомный endpoint для S3 (оставить пустым для AWS S3, заполнить для MinIO или других S3-совместимых сервисов)
-S3_ENDPOINT=
-
-# Yandex Cloud Speech-to-Text Configuration
-# API ключ для доступа к Yandex Cloud (получить в консоли Yandex Cloud)
-YANDEX_CLOUD_API_KEY=your_api_key_here
-# ID папки в Yandex Cloud (получить в консоли Yandex Cloud)
-YANDEX_CLOUD_FOLDER_ID=your_folder_id_here

.gitignore

@@ -48,10 +48,8 @@ Thumbs.db
 # Log files
 *.log
 
-# Environment files
+# Config files
-.env
+config.toml
-.env.local
-.env.*.local
 
 # Sample and test audio files
 *.m4a

Dockerfile

@@ -0,0 +1,72 @@
+# Build stage
+FROM docker.io/library/golang:1.24-alpine AS build-env
+
+# Install build dependencies
+RUN apk --no-cache add \
+    build-base \
+    sqlite-dev \
+    && rm -rf /var/cache/apk/*
+
+# Set up the working directory
+WORKDIR /app
+
+# Copy go mod files
+COPY go.mod go.sum ./
+
+# Download dependencies
+RUN go mod download
+
+# Copy source code
+COPY . .
+
+# Build the application
+RUN go build -o transcriber .
+
+# ----------------
+# Production stage
+# ----------------
+
+FROM docker.io/library/alpine:latest
+
+LABEL maintainer="anton@vakhrushev.me"
+
+# Install runtime dependencies
+RUN apk --no-cache add \
+    ca-certificates \
+    ffmpeg \
+    && rm -rf /var/cache/apk/*
+
+# Create user and group
+RUN addgroup -S -g 1000 transcriber && \
+    adduser -S -H -D \
+    -h /data/transcriber \
+    -s /bin/sh \
+    -u 1000 \
+    -G transcriber \
+    transcriber
+
+# Set environment variables
+ENV USER=transcriber
+
+# Create necessary directories
+RUN mkdir -p /data && chown -R transcriber:transcriber /data
+RUN mkdir -p /config && chown -R transcriber:transcriber /config
+
+# Set working directory
+WORKDIR /app
+
+# Copy the binary from build stage
+COPY --from=build-env /app/transcriber .
+
+# Copy entrypoint script
+COPY docker/entrypoint.sh /usr/bin/entrypoint
+RUN chmod 755 /usr/bin/entrypoint
+
+# Set user
+USER transcriber
+
+EXPOSE 8080
+
+# Set entrypoint and default command
+# ENTRYPOINT ["/usr/bin/entrypoint"]
+CMD ["./transcriber"]

Taskfile.yml

@@ -0,0 +1,28 @@
+# https://taskfile.dev
+
+version: '3'
+
+vars:
+  GREETING: Hello, World!
+
+tasks:
+
+  deploy:
+    vars:
+      COMMIT_HASH:
+        sh: git rev-parse --short HEAD
+      TIMESTAMP:
+        sh: date +%s
+      DOCKER_IMAGE: transcriber:{{.COMMIT_HASH}}-{{.TIMESTAMP}}
+    cmds:
+      - docker build --pull --file Dockerfile --tag {{.DOCKER_IMAGE}} .
+      - task: deploy-with-ansible
+        vars:
+          DOCKER_IMAGE: '{{.DOCKER_IMAGE}}'
+
+  deploy-with-ansible:
+    internal: true
+    requires: 
+      vars: [DOCKER_IMAGE]
+    dir: '/home/av/projects/private/pet-project-server'
+    cmd: ansible-playbook -i production.yml playbook-transcriber.yml --extra-vars 'transcriber_image={{.DOCKER_IMAGE}}'

config.dist.toml

@@ -0,0 +1,45 @@
+# Server configuration
+[server]
+port = 8080
+shutdown_timeout = 5
+force_shutdown_timeout = 20
+
+# Database configuration
+[database]
+path = "data/transcriber.db"
+
+# File storage configuration
+[storage]
+path = "data/files"
+
+# Yandex Cloud Configuration
+[yandex]
+# ID папки в Yandex Cloud (получить в консоли Yandex Cloud)
+folder_id = "your_folder_id_here"
+
+# API ключ для доступа к Yandex SpeechKit (получить в консоли Yandex Cloud)
+speech_kit_api_key = "your_speech_kit_api_key_here"
+
+# Object Storage (S3) configuration
+# Access Key ID для доступа к Object Storage (получить в консоли Yandex Cloud)
+object_storage_access_key_id = "your_access_key_id"
+
+# Secret Access Key для доступа к Object Storage (получить в консоли Yandex Cloud)
+object_storage_secret_access_key = "your_secret_access_key"
+
+# Имя бакета в Object Storage
+object_storage_bucket_name = "your_bucket_name"
+
+# Регион Object Storage
+object_storage_region = "ru-central1"
+
+# Endpoint Object Storage
+object_storage_endpoint = "https://storage.yandexcloud.net/"
+
+# Telegram Bot Configuration
+[telegram]
+# Токен Telegram бота (получить у @BotFather в Telegram)
+bot_token = "your_telegram_bot_token_here"
+
+# Таймаут обновлений Telegram бота (в секундах)
+update_timeout = 10

docker/entrypoint.sh

@@ -0,0 +1,41 @@
+#!/bin/sh
+
+# Protect against buggy runc in docker <20.10.6 causing problems in with Alpine >= 3.14
+if [ ! -x /bin/sh ]; then
+  echo "Executable test for /bin/sh failed. Your Docker version is too old to run Alpine 3.14+ and Gitea. You must upgrade Docker.";
+  exit 1;
+fi
+
+if [ "${USER}" != "transcriber" ]; then
+    # Rename user
+    sed -i -e "s/^transcriber\:/${USER}\:/g" /etc/passwd
+fi
+
+if [ -z "${USER_GID}" ]; then
+  USER_GID="$(id -g ${USER})"
+fi
+
+if [ -z "${USER_UID}" ]; then
+  USER_UID="$(id -u ${USER})"
+fi
+
+# Change GID for USER?
+if [ -n "${USER_GID}" ] && [ "${USER_GID}" != "$(id -g ${USER})" ]; then
+    sed -i -e "s/^${USER}:\([^:]*\):[0-9]*/${USER}:\1:${USER_GID}/" /etc/group
+    sed -i -e "s/^${USER}:\([^:]*\):\([0-9]*\):[0-9]*/${USER}:\1:\2:${USER_GID}/" /etc/passwd
+fi
+
+# Change UID for USER?
+if [ -n "${USER_UID}" ] && [ "${USER_UID}" != "$(id -u ${USER})" ]; then
+    sed -i -e "s/^${USER}:\([^:]*\):[0-9]*:\([0-9]*\)/${USER}:\1:${USER_UID}:\2/" /etc/passwd
+fi
+
+for FOLDER in /data /config; do
+    mkdir -p ${FOLDER}
+done
+
+if [ $# -gt 0 ]; then
+    exec "$@"
+else
+    exec ./transcriber
+fi

go.mod

@@ -3,6 +3,7 @@ module git.vakhrushev.me/av/transcriber
 go 1.24.5
 
 require (
+	github.com/BurntSushi/toml v1.5.0
 	github.com/aws/aws-sdk-go-v2 v1.37.2
 	github.com/aws/aws-sdk-go-v2/config v1.30.3
 	github.com/aws/aws-sdk-go-v2/credentials v1.18.3
@@ -10,10 +11,11 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.86.0
 	github.com/doug-martin/goqu/v9 v9.19.0
 	github.com/gin-gonic/gin v1.10.1
+	github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1
 	github.com/google/uuid v1.6.0
 	github.com/joho/godotenv v1.5.1
-	github.com/mattn/go-sqlite3 v1.14.17
+	github.com/mattn/go-sqlite3 v1.14.31
-	github.com/pressly/goose/v3 v3.15.1
+	github.com/pressly/goose/v3 v3.24.3
 	github.com/prometheus/client_golang v1.23.0
 	github.com/samber/slog-gin v1.15.1
 	github.com/stretchr/testify v1.10.0
@@ -53,6 +55,7 @@ require (
 	github.com/klauspost/cpuid/v2 v2.2.8 // indirect
 	github.com/leodido/go-urn v1.4.0 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/mfridman/interpolate v0.0.2 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
@@ -61,13 +64,16 @@ require (
 	github.com/prometheus/client_model v0.6.2 // indirect
 	github.com/prometheus/common v0.65.0 // indirect
 	github.com/prometheus/procfs v0.16.1 // indirect
+	github.com/sethvargo/go-retry v0.3.0 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.2.12 // indirect
 	go.opentelemetry.io/otel v1.36.0 // indirect
 	go.opentelemetry.io/otel/trace v1.36.0 // indirect
+	go.uber.org/multierr v1.11.0 // indirect
 	golang.org/x/arch v0.8.0 // indirect
 	golang.org/x/crypto v0.38.0 // indirect
 	golang.org/x/net v0.40.0 // indirect
+	golang.org/x/sync v0.14.0 // indirect
 	golang.org/x/sys v0.33.0 // indirect
 	golang.org/x/text v0.25.0 // indirect
 	google.golang.org/genproto/googleapis/api v0.0.0-20250528174236-200df99c418a // indirect

go.sum

@@ -1,3 +1,5 @@
+github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg=
+github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
 github.com/DATA-DOG/go-sqlmock v1.5.0 h1:Shsta01QNfFxHCfpW6YH2STWB0MudeXXEWMr20OEh60=
 github.com/DATA-DOG/go-sqlmock v1.5.0/go.mod h1:f/Ixk793poVmq4qj/V1dPUg2JEAKC73Q5eFN3EC/SaM=
 github.com/aws/aws-sdk-go-v2 v1.37.2 h1:xkW1iMYawzcmYFYEV0UCMxc8gSsjCGEhBXQkdQywVbo=
@@ -77,6 +79,8 @@ github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91
 github.com/go-playground/validator/v10 v10.22.0 h1:k6HsTZ0sTnROkhS//R0O+55JgM8C4Bx7ia+JlgcnOao=
 github.com/go-playground/validator/v10 v10.22.0/go.mod h1:dbuPbCMFw/DrkbEynArYaCwl3amGuJotoKCe95atGMM=
 github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
+github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1 h1:wG8n/XJQ07TmjbITcGiUaOtXxdrINDz1b0J1w0SzqDc=
+github.com/go-telegram-bot-api/telegram-bot-api/v5 v5.5.1/go.mod h1:A2S0CWkNylc2phvKXWBBdD3K0iGnDBGbzRpISP2zBl8=
 github.com/goccy/go-json v0.10.3 h1:KZ5WoDbxAIgm2HNbYckL0se1fHD6rz5j4ywS6ebzDqA=
 github.com/goccy/go-json v0.10.3/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
 github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
@@ -91,8 +95,6 @@ github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
-github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 h1:Z9n2FFNUXsshfwJMBgNA0RU6/i7WVaAegv3PtuIHPMs=
-github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51/go.mod h1:CzGEWj7cYgsdH8dAjBGEr58BoE7ScuLd+fwFZ44+/x8=
 github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
 github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
 github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
@@ -107,14 +109,15 @@ github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0
 github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=
 github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
 github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
+github.com/lib/pq v1.10.1 h1:6VXZrLU0jHBYyAqrSPa+MgPfnSvTPuMgK+k0o5kVFWo=
 github.com/lib/pq v1.10.1/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
-github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
-github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
 github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
 github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
 github.com/mattn/go-sqlite3 v1.14.7/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
-github.com/mattn/go-sqlite3 v1.14.17 h1:mCRHCLDUBXgpKAqIKsaAaAsrAlbkeomtRFKXh2L6YIM=
+github.com/mattn/go-sqlite3 v1.14.31 h1:ldt6ghyPJsokUIlksH63gWZkG6qVGeEAu4zLeS4aVZM=
-github.com/mattn/go-sqlite3 v1.14.17/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
+github.com/mattn/go-sqlite3 v1.14.31/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
+github.com/mfridman/interpolate v0.0.2 h1:pnuTK7MQIxxFz1Gr+rjSIx9u7qVjf5VOoM/u6BbAxPY=
+github.com/mfridman/interpolate v0.0.2/go.mod h1:p+7uk6oE07mpE/Ik1b8EckO0O4ZXiGAfshKBWLUM9Xg=
 github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
@@ -122,12 +125,14 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
 github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
 github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
+github.com/ncruces/go-strftime v0.1.9 h1:bY0MQC28UADQmHmaF5dgpLmImcShSi2kHU9XLdhx/f4=
+github.com/ncruces/go-strftime v0.1.9/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls=
 github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
 github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/pressly/goose/v3 v3.15.1 h1:dKaJ1SdLvS/+HtS8PzFT0KBEtICC1jewLXM+b3emlv8=
+github.com/pressly/goose/v3 v3.24.3 h1:DSWWNwwggVUsYZ0X2VitiAa9sKuqtBfe+Jr9zFGwWlM=
-github.com/pressly/goose/v3 v3.15.1/go.mod h1:0E3Yg/+EwYzO6Rz2P98MlClFgIcoujbVRs575yi3iIM=
+github.com/pressly/goose/v3 v3.24.3/go.mod h1:v9zYL4xdViLHCUUJh/mhjnm6JrK7Eul8AS93IxiZM4E=
 github.com/prometheus/client_golang v1.23.0 h1:ust4zpdl9r4trLY/gSjlm07PuiBq2ynaXXlptpfy8Uc=
 github.com/prometheus/client_golang v1.23.0/go.mod h1:i/o0R9ByOnHX0McrTMTyhYvKE4haaf2mW08I+jGAjEE=
 github.com/prometheus/client_model v0.6.2 h1:oBsgwpGs7iVziMvrGhE53c/GrLUsZdHnqNwqPLxwZyk=
@@ -138,10 +143,12 @@ github.com/prometheus/procfs v0.16.1 h1:hZ15bTNuirocR6u0JZ6BAHHmwS1p8B4P6MRqxtzM
 github.com/prometheus/procfs v0.16.1/go.mod h1:teAbpZRB1iIAJYREa1LsoWUXykVXA1KlTmWl8x/U+Is=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
-github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ=
+github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
-github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog=
+github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
 github.com/samber/slog-gin v1.15.1 h1:jsnfr+S5HQPlz9pFPA3tOmKW7wN/znyZiE6hncucrTM=
 github.com/samber/slog-gin v1.15.1/go.mod h1:mPAEinK/g2jPLauuWO11m3Q0Ca7aG4k9XjXjXY8IhMQ=
+github.com/sethvargo/go-retry v0.3.0 h1:EEt31A35QhrcRZtrYFDTBg91cqZVnFL2navjDrah2SE=
+github.com/sethvargo/go-retry v0.3.0/go.mod h1:mNX17F0C/HguQMyMyJxcnU471gOZGxCLyYaFyAZraas=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
@@ -176,6 +183,8 @@ go.opentelemetry.io/otel/trace v1.36.0 h1:ahxWNuqZjpdiFAyrIoQ4GIiAIhxAunQR6MUoKr
 go.opentelemetry.io/otel/trace v1.36.0/go.mod h1:gQ+OnDZzrybY4k4seLzPAWNwVBBVlF2szhehOBB/tGA=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
 go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
+go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
+go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
 golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
 golang.org/x/arch v0.8.0 h1:3wRIsP3pM4yUptoR96otTUOXI367OS0+c9eeRi9doIc=
 golang.org/x/arch v0.8.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys=
@@ -184,8 +193,8 @@ golang.org/x/crypto v0.0.0-20190325154230-a5d413f7728c/go.mod h1:djNgcEr1/C05ACk
 golang.org/x/crypto v0.0.0-20190605123033-f99c8df09eb5/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/crypto v0.38.0 h1:jt+WWG8IZlBnVbomuhg2Mdq0+BBQaHbtqHEFEigjUV8=
 golang.org/x/crypto v0.38.0/go.mod h1:MvrbAqul58NNYPKnOra203SB9vpuZW0e+RRZV+Ggqjw=
-golang.org/x/mod v0.17.0 h1:zY54UmvipHiNd+pm+m0x9KhZ9hl1/7QNMyxXbc6ICqA=
+golang.org/x/exp v0.0.0-20250506013437-ce4c2cf36ca6 h1:y5zboxd6LQAqYIhHnB48p0ByQ/GnQx2BE33L8BOHQkI=
-golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
+golang.org/x/exp v0.0.0-20250506013437-ce4c2cf36ca6/go.mod h1:U6Lno4MTRCDY+Ba7aCcauB9T60gsv5s4ralQzP72ZoQ=
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.40.0 h1:79Xs7wF06Gbdcg4kdCCIQArK11Z1hr5POQ6+fIYHNuY=
 golang.org/x/net v0.40.0/go.mod h1:y0hY0exeL2Pku80/zKK7tpntoX23cqL3Oa6njdgRtds=
@@ -200,8 +209,6 @@ golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.25.0 h1:qVyWApTSYLk/drJRO5mDlNYskwQznZmkpV2c8q9zls4=
 golang.org/x/text v0.25.0/go.mod h1:WEdwpYrmk1qmdHvhkSTNPm3app7v4rsT8F2UD6+VHIA=
-golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d h1:vU5i/LfpvrRCpgM/VPfJLg5KjxD3E+hfT1SH+d9zLwg=
-golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
 google.golang.org/genproto/googleapis/api v0.0.0-20250528174236-200df99c418a h1:SGktgSolFCo75dnHJF2yMvnns6jCmHFJ0vE4Vn2JKvQ=
 google.golang.org/genproto/googleapis/api v0.0.0-20250528174236-200df99c418a/go.mod h1:a77HrdMjoeKbnd2jmgcWdaS++ZLZAEq3orIOAEIKiVw=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250528174236-200df99c418a h1:v2PbRU4K3llS09c7zodFpNePeamkAwG3mPrAery9VeE=
@@ -216,25 +223,13 @@ gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EV
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-lukechampine.com/uint128 v1.3.0 h1:cDdUVfRwDUDovz610ABgFD17nXD4/uDgVHl2sC3+sbo=
+modernc.org/libc v1.65.0 h1:e183gLDnAp9VJh6gWKdTy0CThL9Pt7MfcR/0bgb7Y1Y=
-lukechampine.com/uint128 v1.3.0/go.mod h1:c4eWIwlEGaxC/+H1VguhU4PHXNWDCDMUlWdIWl2j1gk=
+modernc.org/libc v1.65.0/go.mod h1:7m9VzGq7APssBTydds2zBcxGREwvIGpuUBaKTXdm2Qs=
-modernc.org/cc/v3 v3.41.0 h1:QoR1Sn3YWlmA1T4vLaKZfawdVtSiGx8H+cEojbC7v1Q=
+modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=
-modernc.org/cc/v3 v3.41.0/go.mod h1:Ni4zjJYJ04CDOhG7dn640WGfwBzfE0ecX8TyMB0Fv0Y=
+modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=
-modernc.org/ccgo/v3 v3.16.15 h1:KbDR3ZAVU+wiLyMESPtbtE/Add4elztFyfsWoNTgxS0=
+modernc.org/memory v1.10.0 h1:fzumd51yQ1DxcOxSO+S6X7+QTuVU+n8/Aj7swYjFfC4=
-modernc.org/ccgo/v3 v3.16.15/go.mod h1:yT7B+/E2m43tmMOT51GMoM98/MtHIcQQSleGnddkUNI=
+modernc.org/memory v1.10.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=
-modernc.org/libc v1.24.1 h1:uvJSeCKL/AgzBo2yYIPPTy82v21KgGnizcGYfBHaNuM=
+modernc.org/sqlite v1.37.0 h1:s1TMe7T3Q3ovQiK2Ouz4Jwh7dw4ZDqbebSDTlSJdfjI=
-modernc.org/libc v1.24.1/go.mod h1:FmfO1RLrU3MHJfyi9eYYmZBfi/R+tqZ6+hQ3yQQUkak=
+modernc.org/sqlite v1.37.0/go.mod h1:5YiWv+YviqGMuGw4V+PNplcyaJ5v+vQd7TQOgkACoJM=
-modernc.org/mathutil v1.6.0 h1:fRe9+AmYlaej+64JsEEhoWuAYBkOtQiMEU7n/XgfYi4=
-modernc.org/mathutil v1.6.0/go.mod h1:Ui5Q9q1TR2gFm0AQRqQUaBWFLAhQpCwNcuhBOSedWPo=
-modernc.org/memory v1.7.2 h1:Klh90S215mmH8c9gO98QxQFsY+W451E8AnzjoE2ee1E=
-modernc.org/memory v1.7.2/go.mod h1:NO4NVCQy0N7ln+T9ngWqOQfi7ley4vpwvARR+Hjw95E=
-modernc.org/opt v0.1.3 h1:3XOZf2yznlhC+ibLltsDGzABUGVx8J6pnFMS3E4dcq4=
-modernc.org/opt v0.1.3/go.mod h1:WdSiB5evDcignE70guQKxYUl14mgWtbClRi5wmkkTX0=
-modernc.org/sqlite v1.26.0 h1:SocQdLRSYlA8W99V8YH0NES75thx19d9sB/aFc4R8Lw=
-modernc.org/sqlite v1.26.0/go.mod h1:FL3pVXie73rg3Rii6V/u5BoHlSoyeZeIgKZEgHARyCU=
-modernc.org/strutil v1.2.0 h1:agBi9dp1I+eOnxXeiZawM8F4LawKv4NzGWSaLfyeNZA=
-modernc.org/strutil v1.2.0/go.mod h1:/mdcBmfOibveCTBxUl5B5l6W+TTH1FXPLHZE6bTosX0=
-modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y=
-modernc.org/token v1.1.0/go.mod h1:UGzOrNV1mAFSEB63lOFHIpNRUVMvYTc6yu1SMY/XTDM=
 nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50=
 rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=

internal/config/config.go

@@ -0,0 +1,93 @@
+package config
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/BurntSushi/toml"
+)
+
+type Config struct {
+	Server   ServerConfig   `toml:"server"`
+	Database DatabaseConfig `toml:"database"`
+	Storage  StorageConfig  `toml:"storage"`
+	Yandex   YandexConfig   `toml:"yandex"`
+	Telegram TelegramConfig `toml:"telegram"`
+}
+
+type ServerConfig struct {
+	Port                 int      `toml:"port"`
+	ShutdownTimeout      int      `toml:"shutdown_timeout"`
+	ForceShutdownTimeout int      `toml:"force_shutdown_timeout"`
+	UsersWhiteList       []string `toml:"users_while_list"`
+}
+
+type DatabaseConfig struct {
+	Path string `toml:"path"`
+}
+
+type StorageConfig struct {
+	Path string `toml:"path"`
+}
+
+type YandexConfig struct {
+	FolderID             string `toml:"folder_id"`
+	SpeechKitAPIKey      string `toml:"speech_kit_api_key"`
+	ObjStorageAccessKey  string `toml:"object_storage_access_key_id"`
+	ObjStorageSecretKey  string `toml:"object_storage_secret_access_key"`
+	ObjStorageBucketName string `toml:"object_storage_bucket_name"`
+	ObjStorageRegion     string `toml:"object_storage_region"`
+	ObjStorageEndpoint   string `toml:"object_storage_endpoint"`
+}
+
+type TelegramConfig struct {
+	BotToken      string `toml:"bot_token"`
+	UpdateTimeout int    `toml:"update_timeout"`
+}
+
+// DefaultConfig returns a Config with default values
+func defaultConfig() *Config {
+	return &Config{
+		Server: ServerConfig{
+			Port:                 8080,
+			ShutdownTimeout:      5,
+			ForceShutdownTimeout: 20,
+		},
+		Database: DatabaseConfig{
+			Path: "data/transcriber.db",
+		},
+		Storage: StorageConfig{
+			Path: "data/files",
+		},
+		Yandex: YandexConfig{
+			FolderID:             "",
+			SpeechKitAPIKey:      "",
+			ObjStorageAccessKey:  "",
+			ObjStorageSecretKey:  "",
+			ObjStorageBucketName: "",
+			ObjStorageRegion:     "ru-central1",
+			ObjStorageEndpoint:   "https://storage.yandexcloud.net/",
+		},
+		Telegram: TelegramConfig{
+			BotToken:      "",
+			UpdateTimeout: 10,
+		},
+	}
+}
+
+// LoadConfig loads configuration from a TOML file
+func LoadConfig(path string) (*Config, error) {
+	// Check if file exists
+	if _, err := os.Stat(path); os.IsNotExist(err) {
+		return nil, fmt.Errorf("config file not found: %s", path)
+	}
+
+	config := defaultConfig()
+
+	// Load configuration from file
+	if _, err := toml.DecodeFile(path, &config); err != nil {
+		return nil, fmt.Errorf("failed to decode config file: %w", err)
+	}
+
+	return config, nil
+}

internal/controller/http/transcribe.go

@@ -10,8 +10,6 @@ import (
 	"github.com/gin-gonic/gin"
 )
 
-const baseStorageDir = "data/files"
-
 type TranscribeHandler struct {
 	jobRepo    contract.TranscriptJobRepository
 	trsService *service.TranscribeService

internal/controller/http/transcribe_test.go

@@ -69,7 +69,7 @@ func setupTestRouter(t *testing.T) (*gin.Engine, *TranscribeHandler) {
 		Level: slog.LevelError, // Только ошибки в тестах
 	}))
 
-	trsService := service.NewTranscribeService(jobRepo, fileRepo, metaviewer, converter, recognizer, logger)
+	trsService := service.NewTranscribeService(jobRepo, fileRepo, metaviewer, converter, recognizer, "data/files", logger)
 
 	handler := NewTranscribeHandler(jobRepo, trsService)
 

internal/controller/tg/tg.go

@@ -0,0 +1,361 @@
+package tg
+
+import (
+	"fmt"
+	"io"
+	"log/slog"
+	"net/http"
+	"slices"
+	"strings"
+	"time"
+
+	"git.vakhrushev.me/av/transcriber/internal/contract"
+	"git.vakhrushev.me/av/transcriber/internal/service"
+	tgbotapi "github.com/go-telegram-bot-api/telegram-bot-api/v5"
+)
+
+type TelegramController struct {
+	// deps
+	transcribeService *service.TranscribeService
+	jobRepo           contract.TranscriptJobRepository
+	logger            *slog.Logger
+	// params
+	bot           *tgbotapi.BotAPI
+	userWhiteList []string
+	updateTimeout int
+}
+
+type TelegramConfig struct {
+	BotToken      string
+	UpdateTimeout int
+	UserWhiteList []string
+}
+
+func NewTelegramController(
+	config TelegramConfig,
+	transcribeService *service.TranscribeService,
+	jobRepo contract.TranscriptJobRepository,
+	logger *slog.Logger,
+) (*TelegramController, error) {
+	botToken := config.BotToken
+	if botToken == "" {
+		return nil, &EmptyBotTokenError{}
+	}
+
+	bot, err := tgbotapi.NewBotAPI(botToken)
+	if err != nil {
+		return nil, err
+	}
+
+	controller := &TelegramController{
+		bot:               bot,
+		transcribeService: transcribeService,
+		jobRepo:           jobRepo,
+		logger:            logger,
+		updateTimeout:     config.UpdateTimeout,
+		userWhiteList:     config.UserWhiteList,
+	}
+
+	return controller, nil
+}
+
+func (c *TelegramController) Start() {
+	c.logger.Info("Telegram bot started", "username", c.bot.Self.UserName)
+
+	u := tgbotapi.NewUpdate(0)
+	u.Timeout = c.updateTimeout
+
+	updates := c.bot.GetUpdatesChan(u)
+
+	for update := range updates {
+		if update.Message == nil { // ignore any non-Message updates
+			continue
+		}
+
+		author := update.Message.From.String()
+		c.logger.Info("New incoming message", "author", author)
+
+		if !slices.Contains(c.userWhiteList, author) {
+			c.logger.Info("User is not in white list, reject", "author", author)
+			c.handleForbiddenUser(update.Message)
+			continue
+		}
+
+		// Handle commands
+		if update.Message.IsCommand() {
+			// Extract the command from the Message
+			switch update.Message.Command() {
+			case "start":
+				c.handleStartCommand(update.Message)
+			case "help":
+				c.handleHelpCommand(update.Message)
+			}
+			continue
+		}
+
+		// Handle audio messages and files
+		if update.Message.Audio != nil {
+			c.handleAudioMessage(update.Message)
+		} else if update.Message.Voice != nil {
+			c.handleVoiceMessage(update.Message)
+		} else if update.Message.Document != nil {
+			c.handleDocumentMessage(update.Message)
+		}
+	}
+}
+
+func (c *TelegramController) Stop() {
+	c.bot.StopReceivingUpdates()
+}
+
+func (c *TelegramController) handleStartCommand(message *tgbotapi.Message) {
+	msg := tgbotapi.NewMessage(message.Chat.ID, "Привет! Я бот для расшифровки аудиосообщений. Отправь мне голосовое сообщение или аудиофайл, и я пришлю тебе текст.")
+	msg.ReplyToMessageID = message.MessageID
+
+	c.bot.Send(msg)
+}
+
+func (c *TelegramController) handleForbiddenUser(message *tgbotapi.Message) {
+	msg := tgbotapi.NewMessage(message.Chat.ID, "Извини, тебе нельзя пользоваться этим ботом. Обратись к владельцу бота.")
+	msg.ReplyToMessageID = message.MessageID
+
+	c.bot.Send(msg)
+}
+
+func (c *TelegramController) handleHelpCommand(message *tgbotapi.Message) {
+	helpText := `Я бот для расшифровки аудиосообщений и аудиофайлов.
+
+Просто отправь мне:
+- Голосовое сообщение
+- Аудиофайл (mp3, wav, ogg и др.)
+
+Я пришлю тебе текст расшифровки.
+
+Команды:
+/start - Начало работы с ботом
+/help - Показать эту справку`
+
+	msg := tgbotapi.NewMessage(message.Chat.ID, helpText)
+	msg.ReplyToMessageID = message.MessageID
+
+	c.bot.Send(msg)
+}
+
+func (c *TelegramController) handleAudioMessage(message *tgbotapi.Message) {
+	// Отправляем сообщение о начале обработки
+	progressMsg := tgbotapi.NewMessage(message.Chat.ID, "Обрабатываю аудиофайл...")
+	progressMsg.ReplyToMessageID = message.MessageID
+	sentProgressMsg, err := c.bot.Send(progressMsg)
+	if err != nil {
+		c.logger.Error("Failed to send progress message", "error", err)
+		return
+	}
+
+	// Скачиваем файл
+	fileReader, fileName, err := c.downloadAudioFile(message.Audio.FileID)
+	if err != nil {
+		c.logger.Error("Failed to download audio file", "error", err)
+		errorMsg := tgbotapi.NewMessage(message.Chat.ID, "Ошибка при скачивании аудиофайла. Попробуйте еще раз.")
+		c.bot.Send(errorMsg)
+		return
+	}
+	defer fileReader.Close()
+
+	// Обрабатываем файл
+	job, err := c.transcribeService.CreateTranscribeJob(fileReader, fileName)
+	if err != nil {
+		c.logger.Error("Failed to create transcribe job", "error", err)
+		errorMsg := tgbotapi.NewMessage(message.Chat.ID, "Ошибка при создании задачи на расшифровку. Попробуйте еще раз.")
+		c.bot.Send(errorMsg)
+		return
+	}
+
+	// Отправляем сообщение об успешном создании задачи
+	successMsg := tgbotapi.NewMessage(message.Chat.ID, fmt.Sprintf("Задача на расшифровку создана. ID задачи: %s", job.Id))
+	successMsg.ReplyToMessageID = message.MessageID
+	c.bot.Send(successMsg)
+
+	// Отправляем результат расшифровки (асинхронно)
+	go c.sendTranscriptionResult(message.Chat.ID, job.Id, sentProgressMsg.MessageID)
+}
+
+func (c *TelegramController) handleVoiceMessage(message *tgbotapi.Message) {
+	// Отправляем сообщение о начале обработки
+	progressMsg := tgbotapi.NewMessage(message.Chat.ID, "Обрабатываю голосовое сообщение...")
+	progressMsg.ReplyToMessageID = message.MessageID
+	sentProgressMsg, err := c.bot.Send(progressMsg)
+	if err != nil {
+		c.logger.Error("Failed to send progress message", "error", err)
+		return
+	}
+
+	// Скачиваем файл
+	fileReader, fileName, err := c.downloadAudioFile(message.Voice.FileID)
+	if err != nil {
+		c.logger.Error("Failed to download voice file", "error", err)
+		errorMsg := tgbotapi.NewMessage(message.Chat.ID, "Ошибка при скачивании голосового сообщения. Попробуйте еще раз.")
+		c.bot.Send(errorMsg)
+		return
+	}
+	defer fileReader.Close()
+
+	// Обрабатываем файл
+	job, err := c.transcribeService.CreateTranscribeJob(fileReader, fileName)
+	if err != nil {
+		c.logger.Error("Failed to create transcribe job", "error", err)
+		errorMsg := tgbotapi.NewMessage(message.Chat.ID, "Ошибка при создании задачи на расшифровку. Попробуйте еще раз.")
+		c.bot.Send(errorMsg)
+		return
+	}
+
+	// Отправляем сообщение об успешном создании задачи
+	successMsg := tgbotapi.NewMessage(message.Chat.ID, fmt.Sprintf("Задача на расшифровку создана. ID задачи: %s", job.Id))
+	successMsg.ReplyToMessageID = message.MessageID
+	c.bot.Send(successMsg)
+
+	// Отправляем результат расшифровки (асинхронно)
+	go c.sendTranscriptionResult(message.Chat.ID, job.Id, sentProgressMsg.MessageID)
+}
+
+func (c *TelegramController) handleDocumentMessage(message *tgbotapi.Message) {
+	// Проверяем, является ли документ аудиофайлом
+	if !c.isAudioDocument(message.Document) {
+		return
+	}
+
+	// Отправляем сообщение о начале обработки
+	progressMsg := tgbotapi.NewMessage(message.Chat.ID, "Обрабатываю аудиофайл...")
+	progressMsg.ReplyToMessageID = message.MessageID
+	sentProgressMsg, err := c.bot.Send(progressMsg)
+	if err != nil {
+		c.logger.Error("Failed to send progress message", "error", err)
+		return
+	}
+
+	// Скачиваем файл
+	fileReader, fileName, err := c.downloadAudioFile(message.Document.FileID)
+	if err != nil {
+		c.logger.Error("Failed to download document file", "error", err)
+		errorMsg := tgbotapi.NewMessage(message.Chat.ID, "Ошибка при скачивании аудиофайла. Попробуйте еще раз.")
+		c.bot.Send(errorMsg)
+		return
+	}
+	defer fileReader.Close()
+
+	// Обрабатываем файл
+	job, err := c.transcribeService.CreateTranscribeJob(fileReader, fileName)
+	if err != nil {
+		c.logger.Error("Failed to create transcribe job", "error", err)
+		errorMsg := tgbotapi.NewMessage(message.Chat.ID, "Ошибка при создании задачи на расшифровку. Попробуйте еще раз.")
+		c.bot.Send(errorMsg)
+		return
+	}
+
+	// Отправляем сообщение об успешном создании задачи
+	successMsg := tgbotapi.NewMessage(message.Chat.ID, fmt.Sprintf("Задача на расшифровку создана. ID задачи: %s", job.Id))
+	successMsg.ReplyToMessageID = message.MessageID
+	c.bot.Send(successMsg)
+
+	// Отправляем результат расшифровки (асинхронно)
+	go c.sendTranscriptionResult(message.Chat.ID, job.Id, sentProgressMsg.MessageID)
+}
+
+func (c *TelegramController) downloadAudioFile(fileID string) (io.ReadCloser, string, error) {
+	// Получаем информацию о файле
+	file, err := c.bot.GetFile(tgbotapi.FileConfig{FileID: fileID})
+	if err != nil {
+		return nil, "", fmt.Errorf("failed to get file info: %w", err)
+	}
+
+	// Скачиваем файл
+	fileURL := file.Link(c.bot.Token)
+	resp, err := http.Get(fileURL)
+	if err != nil {
+		return nil, "", fmt.Errorf("failed to download file: %w", err)
+	}
+
+	// Получаем имя файла из URL
+	fileName := file.FilePath
+	if fileName == "" {
+		fileName = "audio.ogg"
+	}
+
+	return resp.Body, fileName, nil
+}
+
+func (c *TelegramController) sendTranscriptionResult(chatID int64, jobID string, progressMessageID int) {
+	// Периодически проверяем статус задачи
+	ticker := time.NewTicker(5 * time.Second)
+	defer ticker.Stop()
+
+	timeout := time.After(10 * time.Minute) // Максимальное время ожидания 10 минут
+
+	for {
+		select {
+		case <-ticker.C:
+			// Проверяем статус задачи
+			job, err := c.jobRepo.GetByID(jobID)
+			if err != nil {
+				c.logger.Error("Failed to get job", "job_id", jobID, "error", err)
+				continue
+			}
+
+			switch job.State {
+			case "done":
+				// Отправляем результат
+				if job.TranscriptionText != nil {
+					resultMsg := tgbotapi.NewMessage(chatID, *job.TranscriptionText)
+					resultMsg.ReplyToMessageID = progressMessageID
+					c.bot.Send(resultMsg)
+				} else {
+					resultMsg := tgbotapi.NewMessage(chatID, "Расшифровка завершена, но текст пуст.")
+					resultMsg.ReplyToMessageID = progressMessageID
+					c.bot.Send(resultMsg)
+				}
+				return
+			case "failed":
+				// Отправляем сообщение об ошибке
+				var errorMsg string
+				if job.ErrorText != nil {
+					errorMsg = fmt.Sprintf("Ошибка при расшифровке: %s", *job.ErrorText)
+				} else {
+					errorMsg = "Ошибка при расшифровке аудиофайла."
+				}
+				resultMsg := tgbotapi.NewMessage(chatID, errorMsg)
+				resultMsg.ReplyToMessageID = progressMessageID
+				c.bot.Send(resultMsg)
+				return
+			}
+		case <-timeout:
+			// Время ожидания истекло
+			resultMsg := tgbotapi.NewMessage(chatID, "Время ожидания результата расшифровки истекло. Попробуйте позже проверить статус задачи.")
+			resultMsg.ReplyToMessageID = progressMessageID
+			c.bot.Send(resultMsg)
+			return
+		}
+	}
+}
+
+func (c *TelegramController) isAudioDocument(document *tgbotapi.Document) bool {
+	// Проверяем MIME-тип документа
+	if document.MimeType != "" {
+		return strings.HasPrefix(document.MimeType, "audio/") || strings.HasPrefix(document.MimeType, "video/")
+	}
+
+	// Проверяем расширение файла
+	audioExtensions := []string{".mp3", ".wav", ".ogg", ".flac", ".m4a", ".aac", ".wma"}
+	filename := document.FileName
+	for _, ext := range audioExtensions {
+		if len(filename) >= len(ext) && strings.ToLower(filename[len(filename)-len(ext):]) == ext {
+			return true
+		}
+	}
+
+	return false
+}
+
+type EmptyBotTokenError struct{}
+
+func (e *EmptyBotTokenError) Error() string {
+	return "telegram bot token is empty"
+}

internal/controller/worker/worker.go

@@ -39,12 +39,12 @@ func (w *CallbackWorker) Name() string {
 }
 
 func (w *CallbackWorker) Start(ctx context.Context) {
-	w.logger.Info("Worker started", "worker_name", w.Name())
+	w.logger.Info("Worker started", "worker", w.Name())
 
 	for {
 		select {
 		case <-ctx.Done():
-			w.logger.Info("Worker received shutdown signal", "worker_name", w.Name())
+			w.logger.Info("Worker received shutdown signal", "worker", w.Name())
 			return
 		default:
 			err := w.f()
@@ -53,13 +53,13 @@ func (w *CallbackWorker) Start(ctx context.Context) {
 				metrics.WorkerJobCounter.WithLabelValues(w.Name(), strconv.FormatBool(err != nil)).Inc()
 			}
 			if err != nil && !isNoop {
-				w.logger.Error("Worker error", "worker_name", w.Name(), "error", err)
+				w.logger.Error("Worker error", "worker", w.Name(), "error", err)
 			}
 
 			// Ждем 1 секунду перед следующей итерацией
 			select {
 			case <-ctx.Done():
-				w.logger.Info("Worker received shutdown signal during sleep", "worker_name", w.Name())
+				w.logger.Info("Worker received shutdown signal during sleep", "worker", w.Name())
 				return
 			case <-time.After(1 * time.Second):
 				// Продолжаем работу

internal/service/transcribe.go

@@ -17,8 +17,6 @@ import (
 )
 
 const (
-	baseStorageDir = "data/files"
-
 	defaultAudioExt = "audio"
 )
 
@@ -28,6 +26,7 @@ type TranscribeService struct {
 	metaviewer  contract.AudioMetaViewer
 	converter   contract.AudioFileConverter
 	recognizer  contract.AudioRecognizer
+	storagePath string
 	logger      *slog.Logger
 }
 
@@ -37,6 +36,7 @@ func NewTranscribeService(
 	metaviewer contract.AudioMetaViewer,
 	converter contract.AudioFileConverter,
 	recognizer contract.AudioRecognizer,
+	storagePath string,
 	logger *slog.Logger,
 ) *TranscribeService {
 	return &TranscribeService{
@@ -45,6 +45,7 @@ func NewTranscribeService(
 		metaviewer:  metaviewer,
 		converter:   converter,
 		recognizer:  recognizer,
+		storagePath: storagePath,
 		logger:      logger,
 	}
 }
@@ -61,7 +62,7 @@ func (s *TranscribeService) CreateTranscribeJob(file io.Reader, fileName string)
 
 	// Создаем путь для сохранения файла
 	storageFileName := fmt.Sprintf("%s%s", fileId, ext)
-	storageFilePath := filepath.Join(baseStorageDir, storageFileName)
+	storageFilePath := filepath.Join(s.storagePath, storageFileName)
 
 	s.logger.Info("Creating transcribe job",
 		"file_id", fileId,
@@ -161,11 +162,11 @@ func (s *TranscribeService) FindAndRunConversionJob() error {
 		return err
 	}
 
-	srcFilePath := filepath.Join(baseStorageDir, srcFile.FileName)
+	srcFilePath := filepath.Join(s.storagePath, srcFile.FileName)
 
 	destFileId := uuid.NewString()
 	destFileName := fmt.Sprintf("%s%s", destFileId, ".ogg")
-	destFilePath := filepath.Join(baseStorageDir, destFileName)
+	destFilePath := filepath.Join(s.storagePath, destFileName)
 
 	// Получаем расширение исходного файла для метрики
 	srcExt := strings.TrimPrefix(filepath.Ext(srcFile.FileName), ".")
@@ -260,7 +261,7 @@ func (s *TranscribeService) FindAndRunTranscribeJob() error {
 		return err
 	}
 
-	filePath := filepath.Join(baseStorageDir, fileRecord.FileName)
+	filePath := filepath.Join(s.storagePath, fileRecord.FileName)
 
 	file, err := os.Open(filePath)
 	if err != nil {

main.go

@@ -3,6 +3,8 @@ package main
 import (
 	"context"
 	"database/sql"
+	"embed"
+	"flag"
 	"fmt"
 	"log/slog"
 	"net/http"
@@ -16,7 +18,9 @@ import (
 	ffmpegmv "git.vakhrushev.me/av/transcriber/internal/adapter/metaviewer/ffmpeg"
 	"git.vakhrushev.me/av/transcriber/internal/adapter/recognizer/yandex"
 	"git.vakhrushev.me/av/transcriber/internal/adapter/repo/sqlite"
+	"git.vakhrushev.me/av/transcriber/internal/config"
 	httpcontroller "git.vakhrushev.me/av/transcriber/internal/controller/http"
+	tgcontroller "git.vakhrushev.me/av/transcriber/internal/controller/tg"
 	"git.vakhrushev.me/av/transcriber/internal/controller/worker"
 	"git.vakhrushev.me/av/transcriber/internal/service"
 	"github.com/doug-martin/goqu/v9"
@@ -29,6 +33,14 @@ import (
 	sloggin "github.com/samber/slog-gin"
 )
 
+//go:embed migrations/*.sql
+var migrationsFS embed.FS
+
+const (
+	ServerShutdownTimeout = 5
+	ForceShutdownTimeout  = 20
+)
+
 func main() {
 	// Создаем структурированный логгер
 	logger := slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{
@@ -36,18 +48,32 @@ func main() {
 	}))
 	slog.SetDefault(logger)
 
+	// Parse command line flags
+	configPath := flag.String("c", "config.toml", "Path to config file")
+	flag.StringVar(configPath, "config", "config.toml", "Path to config file (alias for -c)")
+	flag.Parse()
+
+	// Load configuration
+	cfg, err := config.LoadConfig(*configPath)
+	if err != nil {
+		logger.Error("Unable to load configuration", "config_path", *configPath, "error", err)
+		os.Exit(1)
+	} else {
+		logger.Info("Configuration loaded successfully", "config_path", *configPath)
+	}
+
 	// Загружаем переменные окружения из .env файла
 	if err := godotenv.Load(); err != nil {
 		logger.Warn("Warning: .env file not found, using system environment variables")
 	}
 
 	// Создаем директории если они не существуют
-	if err := os.MkdirAll("data/files", 0755); err != nil {
+	if err := os.MkdirAll(cfg.Storage.Path, 0750); err != nil {
-		logger.Error("Failed to create data/files directory", "error", err)
+		logger.Error("Failed to create file storage directory", "path", cfg.Storage.Path, "error", err)
 		os.Exit(1)
 	}
 
-	db, err := sql.Open("sqlite3", "data/transcriber.db")
+	db, err := sql.Open("sqlite3", cfg.Database.Path)
 	if err != nil {
 		logger.Error("failed to open database", "error", err)
 		os.Exit(1)
@@ -62,7 +88,7 @@ func main() {
 	gq := goqu.New("sqlite3", db)
 
 	// Запускаем миграции
-	if err := RunMigrations(db, "migrations", logger); err != nil {
+	if err := RunMigrations(db, logger); err != nil {
 		logger.Error("Failed to run migrations", "error", err)
 		os.Exit(1)
 	}
@@ -76,13 +102,13 @@ func main() {
 	converter := ffmpegconv.NewFfmpegConverter()
 
 	recognizer, err := yandex.NewYandexAudioRecognizerService(yandex.YandexAudioRecognizerConfig{
-		Region:     os.Getenv("AWS_REGION"),
+		Region:     cfg.Yandex.ObjStorageRegion,
-		AccessKey:  os.Getenv("AWS_ACCESS_KEY_ID"),
+		AccessKey:  cfg.Yandex.ObjStorageAccessKey,
-		SecretKey:  os.Getenv("AWS_SECRET_ACCESS_KEY"),
+		SecretKey:  cfg.Yandex.ObjStorageSecretKey,
-		BucketName: os.Getenv("S3_BUCKET_NAME"),
+		BucketName: cfg.Yandex.ObjStorageBucketName,
-		Endpoint:   os.Getenv("S3_ENDPOINT"),
+		Endpoint:   cfg.Yandex.ObjStorageEndpoint,
-		ApiKey:     os.Getenv("YANDEX_CLOUD_API_KEY"),
+		ApiKey:     cfg.Yandex.SpeechKitAPIKey,
-		FolderID:   os.Getenv("YANDEX_CLOUD_FOLDER_ID"),
+		FolderID:   cfg.Yandex.FolderID,
 	})
 	if err != nil {
 		logger.Error("failed to create audio recognizer", "error", err)
@@ -91,7 +117,44 @@ func main() {
 	defer recognizer.Close()
 
 	// Создаем сервисы
-	transcribeService := service.NewTranscribeService(jobRepo, fileRepo, metaviewer, converter, recognizer, logger)
+	transcribeService := service.NewTranscribeService(
+		jobRepo,
+		fileRepo,
+		metaviewer,
+		converter,
+		recognizer,
+		cfg.Storage.Path,
+		logger,
+	)
+
+	// Создаем контекст для graceful shutdown
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	// Создаем WaitGroup для ожидания завершения всех воркеров
+	var wg sync.WaitGroup
+
+	tgConfig := tgcontroller.TelegramConfig{
+		BotToken:      cfg.Telegram.BotToken,
+		UpdateTimeout: cfg.Telegram.UpdateTimeout,
+		UserWhiteList: cfg.Server.UsersWhiteList,
+	}
+
+	// Создаем Telegram бот
+	tgController, err := tgcontroller.NewTelegramController(tgConfig, transcribeService, jobRepo, logger)
+	if err != nil {
+		logger.Error("Failed to create Telegram controller", "error", err)
+		// Не останавливаем приложение, если Telegram бот не создан
+	} else {
+		// Запускаем Telegram бот в отдельной горутине
+		wg.Add(1)
+		go func() {
+			defer wg.Done()
+			logger.Info("Starting Telegram bot")
+			tgController.Start()
+			logger.Info("Telegram bot stopped gracefully")
+		}()
+	}
 
 	// Создаем воркеры
 	conversionWorker := worker.NewCallbackWorker("conversion_worker", transcribeService.FindAndRunConversionJob, logger)
@@ -104,20 +167,13 @@ func main() {
 		checkWorker,
 	}
 
-	// Создаем контекст для graceful shutdown
-	ctx, cancel := context.WithCancel(context.Background())
-	defer cancel()
-
-	// Создаем WaitGroup для ожидания завершения всех воркеров
-	var wg sync.WaitGroup
-
 	// Запускаем воркеры в отдельных горутинах
 	for _, w := range workers {
 		wg.Add(1)
 		go func(worker worker.Worker) {
 			defer wg.Done()
 			worker.Start(ctx)
-			logger.Info("Worker stopped", "worker_name", worker.Name())
+			logger.Info("Worker stopped gracefully", "worker", worker.Name())
 		}(w)
 	}
 
@@ -153,7 +209,7 @@ func main() {
 
 	// Создаем HTTP сервер
 	srv := &http.Server{
-		Addr:    ":8080",
+		Addr:    fmt.Sprintf(":%d", cfg.Server.Port),
 		Handler: router,
 	}
 
@@ -161,7 +217,7 @@ func main() {
 	wg.Add(1)
 	go func() {
 		defer wg.Done()
-		logger.Info("Starting HTTP server", "port", 8080)
+		logger.Info("Starting HTTP server", "port", cfg.Server.Port)
 		if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
 			logger.Error("HTTP server error", "error", err)
 		}
@@ -179,8 +235,13 @@ func main() {
 	<-sigChan
 	logger.Info("Received shutdown signal, initiating graceful shutdown...")
 
+	if tgController != nil {
+		logger.Info("Shutting down Telegram bot...")
+		tgController.Stop()
+	}
+
 	// Создаем контекст с таймаутом для graceful shutdown HTTP сервера
-	shutdownCtx, shutdownCancel := context.WithTimeout(context.Background(), 5*time.Second)
+	shutdownCtx, shutdownCancel := context.WithTimeout(context.Background(), time.Duration(cfg.Server.ShutdownTimeout)*time.Second)
 	defer shutdownCancel()
 
 	// Останавливаем HTTP сервер
@@ -201,23 +262,26 @@ func main() {
 		close(done)
 	}()
 
-	// Ждем завершения всех воркеров или таймаута в 10 секунд
+	// Ждем завершения всех воркеров или таймаута
 	select {
 	case <-done:
 		logger.Info("All workers stopped gracefully")
-	case <-time.After(10 * time.Second):
+	case <-time.After(time.Duration(cfg.Server.ForceShutdownTimeout) * time.Second):
 		logger.Warn("Timeout reached, forcing shutdown")
 	}
 
 	logger.Info("Transcriber service stopped")
 }
 
-func RunMigrations(db *sql.DB, migrationsDir string, logger *slog.Logger) error {
+func RunMigrations(db *sql.DB, logger *slog.Logger) error {
 	if err := goose.SetDialect("sqlite3"); err != nil {
 		return fmt.Errorf("failed to set goose dialect: %w", err)
 	}
 
-	if err := goose.Up(db, migrationsDir); err != nil {
+	// Use the embedded filesystem for migrations
+	goose.SetBaseFS(migrationsFS)
+
+	if err := goose.Up(db, "migrations"); err != nil {
 		return fmt.Errorf("failed to run migrations: %w", err)
 	}