feat: apis to support s3/sftp datasources import

server/api/studio/internal/logic/datasource/datasourceaddlogic.go

@@ -0,0 +1,29 @@
+package datasource
+
+import (
+	"context"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/service"
+
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type DatasourceAddLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewDatasourceAddLogic(ctx context.Context, svcCtx *svc.ServiceContext) DatasourceAddLogic {
+	return DatasourceAddLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *DatasourceAddLogic) DatasourceAdd(req types.DatasourceAddRequest) (resp *types.DatasourceAddData, err error) {
+	return service.NewDatasourceService(l.ctx, l.svcCtx).Add(req)
+}

server/api/studio/internal/logic/datasource/datasourcelistcontentslogic.go

@@ -0,0 +1,29 @@
+package datasource
+
+import (
+	"context"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/service"
+
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type DatasourceListContentsLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewDatasourceListContentsLogic(ctx context.Context, svcCtx *svc.ServiceContext) DatasourceListContentsLogic {
+	return DatasourceListContentsLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *DatasourceListContentsLogic) DatasourceListContents(req types.DatasourceListContentsRequest) (resp *types.DatasourceListContentsData, err error) {
+	return service.NewDatasourceService(l.ctx, l.svcCtx).ListContents(req)
+}

server/api/studio/internal/logic/datasource/datasourcelistlogic.go

@@ -0,0 +1,29 @@
+package datasource
+
+import (
+	"context"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/service"
+
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type DatasourceListLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewDatasourceListLogic(ctx context.Context, svcCtx *svc.ServiceContext) DatasourceListLogic {
+	return DatasourceListLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *DatasourceListLogic) DatasourceList() (resp *types.DatasourceData, err error) {
+	return service.NewDatasourceService(l.ctx, l.svcCtx).List()
+}

server/api/studio/internal/logic/datasource/datasourcepreviewfilelogic.go

@@ -0,0 +1,29 @@
+package datasource
+
+import (
+	"context"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/service"
+
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type DatasourcePreviewFileLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewDatasourcePreviewFileLogic(ctx context.Context, svcCtx *svc.ServiceContext) DatasourcePreviewFileLogic {
+	return DatasourcePreviewFileLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *DatasourcePreviewFileLogic) DatasourcePreviewFile(req types.DatasourcePreviewFileRequest) (resp *types.DatasourcePreviewFileData, err error) {
+	return service.NewDatasourceService(l.ctx, l.svcCtx).PreviewFile(req)
+}

server/api/studio/internal/logic/datasource/datasourceremovelogic.go

@@ -0,0 +1,29 @@
+package datasource
+
+import (
+	"context"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/service"
+
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc"
+	"github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type DatasourceRemoveLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewDatasourceRemoveLogic(ctx context.Context, svcCtx *svc.ServiceContext) DatasourceRemoveLogic {
+	return DatasourceRemoveLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *DatasourceRemoveLogic) DatasourceRemove(req types.DatasourceRemoveRequest) error {
+	return service.NewDatasourceService(l.ctx, l.svcCtx).Remove(req)
+}

server/api/studio/internal/model/datasource.go

@@ -0,0 +1,14 @@
+package db
+
+import "time"
+
+type Datasource struct {
+	ID         int       `json:"id" gorm:"primaryKey;autoIncrement"`
+	Name       string    `json:"name"`
+	Type       string    `json:"type"`
+	Config     string    `json:"config"`
+	Secret     string    `json:"secret"`
+	Host       string    `json:"host"`
+	Username   string    `json:"username"`
+	CreateTime time.Time `json:"create_time" gorm:"autoCreateTime"`
+}

server/api/studio/internal/model/db.go

@@ -23,6 +23,7 @@ func InitDB(sqlitedbFilePath string) {
 		zap.L().Fatal(fmt.Sprintf("init db fail: %s", err))
 	}
 	err = db.AutoMigrate(
+		&Datasource{},
 		&TaskInfo{},
 		&Sketch{},
 		&SchemaSnapshot{},