Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Empty file added llmstack/assets/__init__.py
Empty file.
Empty file added llmstack/assets/admin.py
Empty file.
6 changes: 6 additions & 0 deletions llmstack/assets/apps.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
from django.apps import AppConfig


class AssetsConfig(AppConfig):
name = "assets"
label = "assets"
49 changes: 49 additions & 0 deletions llmstack/assets/models.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,49 @@
import base64
import uuid

from django.db import models
from django.db.models.signals import pre_delete
from django.dispatch import receiver


class Assets(models.Model):
uuid = models.UUIDField(default=uuid.uuid4, editable=False, help_text="UUID of the asset")
path = None
file = None
metadata = models.JSONField(
default=dict,
help_text="Metadata for the asset",
null=True,
blank=True,
)
created_at = models.DateTimeField(auto_now_add=True)

@classmethod
def create_from_bytes(cls, file_bytes, filename, metadata=None, path=""):
from django.core.files.base import ContentFile

asset = cls(path=path)
asset.file.save(filename, ContentFile(file_bytes))
bytes_size = len(file_bytes)
asset.metadata = {**metadata, "file_size": bytes_size}
asset.save()
return asset

@classmethod
def create_from_data_uri(cls, data_uri, metadata={}, path=""):
from llmstack.common.utils.utils import validate_parse_data_uri

mime_type, file_name, file_data = validate_parse_data_uri(data_uri)
file_bytes = base64.b64decode(file_data)
return cls.create_from_bytes(
file_bytes, file_name, {**metadata, "mime_type": mime_type, "file_name": file_name}, path=path
)

class Meta:
abstract = True


@receiver(pre_delete)
def delete_file_on_delete(sender, instance, **kwargs):
if issubclass(sender, Assets) and instance.file:
instance.file.delete(False)
3 changes: 1 addition & 2 deletions llmstack/datasources/admin.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
from django.contrib import admin

from .models import DataSource, DataSourceEntry, DataSourceType, UserFiles
from .models import DataSource, DataSourceEntry, DataSourceType


class DataSourceEntryAdmin(admin.ModelAdmin):
Expand All @@ -15,4 +15,3 @@ class DataSourceAdmin(admin.ModelAdmin):
admin.site.register(DataSourceEntry, DataSourceEntryAdmin)
admin.site.register(DataSourceType, DataSourceAdmin)
admin.site.register(DataSource)
admin.site.register(UserFiles)
16 changes: 16 additions & 0 deletions llmstack/datasources/migrations/0005_delete_userfiles.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
# Generated by Django 4.2.10 on 2024-03-21 00:01

from django.db import migrations


class Migration(migrations.Migration):

dependencies = [
('datasources', '0004_alter_userfiles_user'),
]

operations = [
migrations.DeleteModel(
name='UserFiles',
),
]
59 changes: 0 additions & 59 deletions llmstack/datasources/models.py
Original file line number Diff line number Diff line change
@@ -1,15 +1,11 @@
import base64
import logging
import uuid

from django.contrib.auth.models import User
from django.db import models
from django.db.models.signals import pre_delete
from django.dispatch import receiver
from django.utils.timezone import now

from llmstack.base.models import Profile
from llmstack.common.utils.utils import validate_parse_data_uri

logger = logging.getLogger(__name__)

Expand Down Expand Up @@ -196,58 +192,3 @@ def upload_to(instance, filename):
filename,
]
)


class UserFiles(models.Model):
uuid = models.UUIDField(default=uuid.uuid4, editable=False, help_text="UUID of the asset")
user = models.ForeignKey(User, on_delete=models.DO_NOTHING, help_text="User this asset belongs to")
path = ""
file = models.FileField(
storage=select_storage,
upload_to=upload_to,
null=True,
blank=True,
)
metadata = models.JSONField(
default=dict,
help_text="Metadata for the asset",
null=True,
blank=True,
)
created_at = models.DateTimeField(auto_now_add=True)

def __init__(self, *args, path="", **kwargs) -> None:
super(UserFiles, self).__init__(*args, **kwargs)
self.path = path

@property
def profile_uuid(self):
return Profile.objects.get(user=self.user).uuid


@receiver(pre_delete, sender=UserFiles)
def delete_file_on_delete(sender, instance, **kwargs):
if instance.file:
instance.file.delete(False)


def create_from_bytes(user, file_bytes, filename, metadata=None, path=""):
from django.core.files.base import ContentFile

asset = UserFiles(user=user, path=path)
asset.file.save(
filename,
ContentFile(file_bytes),
)
bytes_size = len(file_bytes)
asset.metadata = {**metadata, "file_size": bytes_size}
asset.save()
return asset


def create_from_data_uri(user, data_uri, metadata={}, path=""):
mime_type, file_name, file_data = validate_parse_data_uri(data_uri)
file_bytes = base64.b64decode(file_data)
return create_from_bytes(
user, file_bytes, file_name, {**metadata, "mime_type": mime_type, "file_name": file_name}, path=path
)
3 changes: 2 additions & 1 deletion llmstack/server/settings.py
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,7 @@
"llmstack.connections.apps.ConnectionsConfig",
"llmstack.jobs.apps.JobsConfig",
"llmstack.organizations.apps.OrganizationsConfig",
"llmstack.assets.apps.AssetsConfig",
"flags",
"allauth",
"allauth.account",
Expand Down Expand Up @@ -208,7 +209,7 @@
"base_url": GENERATEDFILES_URL,
},
},
"useruploads": {
"assets": {
"BACKEND": "django.core.files.storage.FileSystemStorage",
},
}
Expand Down