initialize package

code-creeper · code-creeper · commit 456e8f903f4c · 2025-03-26T05:23:02.000+05:00
diff --git a/.github/FUNDING.yml b/.github/FUNDING.yml
@@ -1 +1 @@
-github: Abdul Haseeb Khan
+github: code-creeper
diff --git a/README.md b/README.md
@@ -76,7 +76,7 @@ Please review [our security policy](../../security/policy) on how to report secu
 
 ## Credits
 
-- [Abdul Haseeb Khan](https://github.com/code-creeper)
+- [Code Creeper](https://github.com/code-creeper)
 - [All Contributors](../../contributors)
 
 ## License
diff --git a/composer.json b/composer.json
@@ -39,8 +39,7 @@
     },
     "autoload": {
         "psr-4": {
-            "CodeCreeper\\Chunkify\\": "src/",
-            "CodeCreeper\\Chunkify\\Database\\Factories\\": "database/factories/"
+            "CodeCreeper\\Chunkify\\": "src/"
         }
     },
     "autoload-dev": {
diff --git a/config/chunkify.php b/config/chunkify.php
@@ -1,6 +1,21 @@
 <?php
 
-// config for CodeCreeper/Chunkify
 return [
+    'chunk_disk' => env('CHUNKIFY_CHUNK_DISK', 'public'),
+    'file_disk' => env('CHUNKIFY_FILE_DISK', 'public'),
 
+    'files_model' => CodeCreeper\Chunkify\Models\ChunkifyFile::class,
+    'chunks_model' => CodeCreeper\Chunkify\Models\ChunkifyChunk::class,
+
+    'path_prefix' => env('CHUNKIFY_PATH_PREFIX', 'chunkify'),
+
+    'path_generator' => \CodeCreeper\Chunkify\ChunkifyPathGenerator::class,
+
+    'request' => [
+        'chunk_reference' => 'chunk_reference',
+        'chunk_extension' => 'chunk_extension',
+        'chunk_index' => 'chunk_index',
+        'chunk_total_count' => 'chunk_total_count',
+        'chunk_data' => 'chunk_data',
+    ]
 ];
diff --git a/database/factories/ModelFactory.php b/database/factories/ModelFactory.php
diff --git a/database/migrations/create_chunkify_table.php b/database/migrations/create_chunkify_table.php
@@ -0,0 +1,49 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::create('chunkify_files', function (Blueprint $table) {
+            $table->id();
+            $table->string('reference')->unique();
+            $table->string('extension')->nullable();
+            $table->string('name')->nullable();
+            $table->string('disk');
+            $table->unsignedSmallInteger('expected_chunks_count');
+            $table->unsignedSmallInteger('uploaded_chunks_count');
+            $table->boolean('completed')->default(false);
+            $table->timestamps();
+
+            $table->index(['reference']);
+            $table->index(['reference', 'completed']);
+        });
+
+        Schema::create('chunkify_chunks', function (Blueprint $table) {
+            $table->id();
+            $table->foreignId('chunkify_file_id')
+                ->constrained()
+                ->cascadeOnUpdate()
+                ->cascadeOnDelete();
+            $table->string('name');
+            $table->unsignedMediumInteger('index');
+            $table->string('disk');
+            $table->timestamps();
+
+            $table->unique(['chunkify_file_id', 'index']);
+
+            $table->index(['chunkify_file_id']);
+            $table->index(['chunkify_file_id', 'index']);
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::dropIfExists('chunkify_chunks');
+        Schema::dropIfExists('chunkify_files');
+    }
+};
diff --git a/database/migrations/create_chunkify_table.php.stub b/database/migrations/create_chunkify_table.php.stub
diff --git a/phpstan.neon.dist b/phpstan.neon.dist
@@ -4,9 +4,11 @@ includes:
 parameters:
     level: 5
     paths:
-        - src
         - config
         - database
+        - routes
+        - src
+        - tests
     tmpDir: build/phpstan
     checkOctaneCompatibility: true
     checkModelProperties: true
diff --git a/routes/web.php b/routes/web.php
@@ -0,0 +1,8 @@
+<?php
+
+use CodeCreeper\Chunkify\Controllers\ChunkifyController;
+use Illuminate\Support\Facades\Route;
+
+Route::prefix('/chunkify')->group(function () {
+    Route::post('/chunkify', ChunkifyController::class)->name('chunkify');
+});
diff --git a/src/Chunkify.php b/src/Chunkify.php
diff --git a/src/ChunkifyPathGenerator.php b/src/ChunkifyPathGenerator.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace CodeCreeper\Chunkify;
+
+class ChunkifyPathGenerator
+{
+
+}
diff --git a/src/ChunkifyServiceProvider.php b/src/ChunkifyServiceProvider.php
@@ -2,6 +2,8 @@
 
 namespace CodeCreeper\Chunkify;
 
+use Illuminate\Contracts\Foundation\CachesRoutes;
+use Illuminate\Support\Facades\Route;
 use Spatie\LaravelPackageTools\Package;
 use Spatie\LaravelPackageTools\PackageServiceProvider;
 use CodeCreeper\Chunkify\Commands\ChunkifyCommand;
@@ -10,16 +12,12 @@ class ChunkifyServiceProvider extends PackageServiceProvider
 {
     public function configurePackage(Package $package): void
     {
-        /*
-         * This class is a Package Service Provider
-         *
-         * More info: https://github.com/spatie/laravel-package-tools
-         */
         $package
             ->name('laravel-chunkify')
             ->hasConfigFile()
-            ->hasViews()
-            ->hasMigration('create_laravel_chunkify_table')
+            ->hasRoute('web')
+            ->hasMigration('create_chunkify_table')
+            ->runsMigrations()
             ->hasCommand(ChunkifyCommand::class);
     }
 }
diff --git a/src/Controllers/ChunkifyController.php b/src/Controllers/ChunkifyController.php
@@ -0,0 +1,112 @@
+<?php
+
+namespace CodeCreeper\Chunkify\Controllers;
+
+use CodeCreeper\Chunkify\Models\ChunkifyChunk;
+use CodeCreeper\Chunkify\Models\ChunkifyFile;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Request;
+use Illuminate\Http\UploadedFile;
+use Illuminate\Support\Facades\App;
+use Illuminate\Support\Facades\Config;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Response;
+use Illuminate\Support\Facades\Storage;
+use Illuminate\Support\Str;
+
+class ChunkifyController
+{
+    public function __invoke(Request $request): JsonResponse
+    {
+        $request->validate([
+            Config::get('chunkify.request.chunk_reference') => 'required',
+            Config::get('chunkify.request.chunk_extension') => 'required',
+            Config::get('chunkify.request.chunk_index') => 'required',
+            Config::get('chunkify.request.chunk_total_count') => 'required',
+            Config::get('chunkify.request.chunk_data') => 'required',
+        ]);
+
+        $extension = $request->get(Config::get('chunkify.request.chunk_extension'));
+        $index = $request->get(Config::get('chunkify.request.chunk_index'));
+        $reference = $request->get(Config::get('chunkify.request.chunk_reference'));
+        $totalCount = $request->get(Config::get('chunkify.request.chunk_total_count'));
+        $data = $request->file(Config::get('chunkify.request.chunk_data'))
+            ?? $request->input(Config::get('chunkify.request.chunk_data'));
+        $fileDisk = Config::get('chunkify.file_disk');
+        $chunkDisk = Config::get('chunkify.chunk_disk');
+
+        DB::beginTransaction();
+
+        try {
+            /** @var Model $chunkifyFileClass */
+            $chunkifyFileClass = App::make(Config::get('chunkify.files_model'));
+
+            /** @var ChunkifyFile $chunkifyFile */
+            $chunkifyFile = $chunkifyFileClass::firstOrCreate(
+                ['reference' => $reference],
+                [
+                    'extension' => $extension,
+                    'disk' => $fileDisk,
+                    'expected_chunks_count' => $totalCount,
+                    'uploaded_chunks_count' => 0,
+                    'name' => Str::random(),
+                ]
+            );
+
+            /**
+             * @var ChunkifyChunk $chunkifyChunk
+             */
+            $chunkifyChunk = $chunkifyFile->chunks()->create([
+                'index' => $index,
+                'disk' => $chunkDisk,
+                'name' => $index . '_' . Str::random(),
+            ]);
+
+            if ($data instanceof UploadedFile) {
+                $content = $data->getContent();
+            } else {
+                $content = $data;
+            }
+
+            $directory = "chunkify/{$chunkifyFile->id}";
+
+            Storage::disk($chunkDisk)->put("$directory/{$chunkifyChunk->name}.blob", $content);
+
+            $chunkifyFile->increment('uploaded_chunks_count');
+            $chunkifyFile->refresh();
+
+            if ($chunkifyFile->uploaded_chunks_count == $chunkifyFile->expected_chunks_count) {
+                $mergeFilePath = "$directory/{$chunkifyFile->name}.{$extension}";
+
+                $outputStream = fopen(Storage::disk($chunkDisk)->path($mergeFilePath), 'w');
+
+                foreach ($chunkifyFile->chunks()->cursor() as $chunk) {
+                    $chunkFilePath = $chunk->getFilePath();
+                    $chunkFileStream = fopen($chunkFilePath, 'r');
+
+                    stream_copy_to_stream($chunkFileStream, $outputStream);
+
+                    fclose($chunkFileStream);
+                }
+
+                fclose($outputStream);
+
+                $chunkifyFile->update(['completed' => true]);
+            }
+        } catch (\Throwable $throwable) {
+            DB::rollBack();
+
+            return Response::json([
+                'error' => $throwable->getMessage(),
+                'completed' => false,
+            ], 500);
+        }
+
+        DB::commit();
+
+        return Response::json([
+            'completed' => $chunkifyFile->completed
+        ]);
+    }
+}
diff --git a/src/Models/ChunkifyChunk.php b/src/Models/ChunkifyChunk.php
@@ -0,0 +1,31 @@
+<?php
+
+namespace CodeCreeper\Chunkify\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Support\Facades\Config;
+use Illuminate\Support\Facades\Storage;
+use Illuminate\Support\Str;
+
+/**
+ * @property string $name
+ * @property int $chunkify_file_id
+ * @property int $index
+ * @property string $disk
+ */
+class ChunkifyChunk extends Model
+{
+    protected $table = 'chunkify_chunks';
+
+    protected $guarded = ['id'];
+
+    public function getFilePath(): string
+    {
+        return Storage::disk(Config::get('chunkify.chunk_disk'))->path("chunkify/{$this->chunkify_file_id}/{$this->name}.blob");
+    }
+
+    public function getFileContent(): string
+    {
+        return Storage::disk(Config::get('chunkify.chunk_disk'))->get("chunkify/{$this->chunkify_file_id}/{$this->name}.blob");
+    }
+}
diff --git a/src/Models/ChunkifyFile.php b/src/Models/ChunkifyFile.php
@@ -0,0 +1,46 @@
+<?php
+
+namespace CodeCreeper\Chunkify\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\HasMany;
+use Illuminate\Support\Facades\Config;
+use Illuminate\Support\Facades\Storage;
+use Illuminate\Support\Str;
+
+/**
+ * @property int $id
+ * @property int $uploaded_chunks_count
+ * @property int $expected_chunks_count
+ * @property bool $completed
+ * @property string $extension
+ * @property string $name
+ */
+class ChunkifyFile extends Model
+{
+    protected $table = 'chunkify_files';
+
+    protected $guarded = ['id'];
+
+    protected function casts(): array
+    {
+        return [
+            'completed' => 'boolean',
+        ];
+    }
+
+    public function chunks(): HasMany
+    {
+        return $this->hasMany(Config::get('chunkify.chunks_model'))->orderBy('index');
+    }
+
+    public function getFilePath(): string
+    {
+        return Storage::disk(Config::get('chunkify.file_disk'))->path("chunkify/{$this->id}/{$this->name}.{$this->extension}");
+    }
+
+    public function getDiskPath(): string
+    {
+        return "chunkify/{$this->id}/{$this->name}.{$this->extension}";
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-github: Abdul Haseeb Khan`
	`1`	`+github: code-creeper`