@@ -47,7 +47,7 @@ func ValidateAndLoadPlugin(itOrm *gorm.DB, logger *zap.Logger, data []byte) erro
47
47
}
48
48
49
49
func LoadPlugin (itOrm * gorm.DB , logger * zap.Logger , plugin platformspec.PluginSpecification ) error {
50
- dbPlugin , pluginBinary , err := ExtractIntegrationBinaries (logger , plugin )
50
+ dbPlugin , _ , err := ExtractIntegrationBinaries (logger , plugin )
51
51
if err != nil {
52
52
return err
53
53
}
@@ -62,26 +62,26 @@ func LoadPlugin(itOrm *gorm.DB, logger *zap.Logger, plugin platformspec.PluginSp
62
62
return err
63
63
}
64
64
65
- err = itOrm .Clauses (clause.OnConflict {
66
- Columns : []clause.Column {{Name : "plugin_id" }},
67
- DoUpdates : clause .Assignments (map [string ]interface {}{
68
- "integration_plugin" : gorm .Expr (
69
- "CASE WHEN ? <> '' THEN CAST(? AS bytea) ELSE integration_plugin_binaries.integration_plugin END" ,
70
- pluginBinary .IntegrationPlugin ,
71
- pluginBinary .IntegrationPlugin ,
72
- ),
73
- "cloud_ql_plugin" : gorm .Expr (
74
- "CASE WHEN ? <> '' THEN CAST(? AS bytea) ELSE integration_plugin_binaries.cloud_ql_plugin END" ,
75
- pluginBinary .CloudQlPlugin ,
76
- pluginBinary .CloudQlPlugin ,
77
- ),
78
- }),
79
- }).Create (pluginBinary ).Error
80
- if err != nil {
81
- logger .Error ("failed to create integration binary" , zap .Error (err ))
82
- return err
83
- }
84
- pluginBinary = nil
65
+ // err = itOrm.Clauses(clause.OnConflict{
66
+ // Columns: []clause.Column{{Name: "plugin_id"}},
67
+ // DoUpdates: clause.Assignments(map[string]interface{}{
68
+ // "integration_plugin": gorm.Expr(
69
+ // "CASE WHEN ? <> '' THEN CAST(? AS bytea) ELSE integration_plugin_binaries.integration_plugin END",
70
+ // pluginBinary.IntegrationPlugin,
71
+ // pluginBinary.IntegrationPlugin,
72
+ // ),
73
+ // "cloud_ql_plugin": gorm.Expr(
74
+ // "CASE WHEN ? <> '' THEN CAST(? AS bytea) ELSE integration_plugin_binaries.cloud_ql_plugin END",
75
+ // pluginBinary.CloudQlPlugin,
76
+ // pluginBinary.CloudQlPlugin,
77
+ // ),
78
+ // }),
79
+ // }).Create(pluginBinary).Error
80
+ // if err != nil {
81
+ // logger.Error("failed to create integration binary", zap.Error(err))
82
+ // return err
83
+ // }
84
+ // pluginBinary = nil
85
85
86
86
logger .Info ("integration binary created" )
87
87
@@ -107,8 +107,8 @@ func ExtractIntegrationBinaries(logger *zap.Logger, plugin platformspec.PluginSp
107
107
err = tagsJsonb .Set (tagsJsonData )
108
108
109
109
// download files from urls
110
- binaries := & models.IntegrationPluginBinary {
111
- PluginID : plugin .IntegrationType .String ()}
110
+ // binaries := &models.IntegrationPluginBinary{
111
+ // PluginID: plugin.IntegrationType.String()}
112
112
var describerURL , describerTags , demoDataUrl , url string
113
113
discoveryType := models .IntegrationPluginDiscoveryTypeClassic
114
114
installState := models .IntegrationTypeInstallStateNotInstalled
@@ -153,14 +153,14 @@ func ExtractIntegrationBinaries(logger *zap.Logger, plugin platformspec.PluginSp
153
153
discoveryType = models .IntegrationPluginDiscoveryTypeTask
154
154
}
155
155
logger .Info ("platform binary path" , zap .String ("path" , baseDir + "/integarion_type/" + plugin .Components .PlatformBinary .PathInArchive ))
156
- binaries .IntegrationPlugin , err = os .ReadFile (baseDir + "/integarion_type/" + plugin .Components .PlatformBinary .PathInArchive )
157
- if err != nil {
158
- logger .Error ("failed to open integration-plugin file" , zap .Error (err ), zap .String ("url" , plugin .Components .PlatformBinary .URI ))
159
- return nil , nil , fmt .Errorf ("open integration-plugin file for url %s: %w" , plugin , err )
160
- }
161
-
162
- installState = models .IntegrationTypeInstallStateInstalled
163
- operationalStatus = models .IntegrationPluginOperationalStatusEnabled
156
+ // binaries.IntegrationPlugin, err = os.ReadFile(baseDir + "/integarion_type/" + plugin.Components.PlatformBinary.PathInArchive)
157
+ // if err != nil {
158
+ // logger.Error("failed to open integration-plugin file", zap.Error(err), zap.String("url", plugin.Components.PlatformBinary.URI))
159
+ // return nil, nil, fmt.Errorf("open integration-plugin file for url %s: %w", plugin, err)
160
+ // }
161
+
162
+ // installState = models.IntegrationTypeInstallStateInstalled
163
+ // operationalStatus = models.IntegrationPluginOperationalStatusEnabled
164
164
}
165
165
if plugin .Components .CloudQLBinary .URI != "" && plugin .Components .CloudQLBinary .PathInArchive != "" {
166
166
if plugin .Components .CloudQLBinary .URI != plugin .Components .PlatformBinary .URI {
@@ -179,11 +179,11 @@ func ExtractIntegrationBinaries(logger *zap.Logger, plugin platformspec.PluginSp
179
179
}
180
180
181
181
logger .Info ("cloudql binary path" , zap .String ("path" , baseDir + "/integarion_type/" + plugin .Components .CloudQLBinary .PathInArchive ))
182
- binaries .CloudQlPlugin , err = os .ReadFile (baseDir + "/integarion_type/" + plugin .Components .CloudQLBinary .PathInArchive )
183
- if err != nil {
184
- logger .Error ("failed to open cloudql-plugin file" , zap .Error (err ), zap .String ("url" , plugin .Components .CloudQLBinary .URI ))
185
- return nil , nil , fmt .Errorf ("open cloudql-plugin file for url %s: %w" , plugin .IntegrationType .String (), err )
186
- }
182
+ // binaries.CloudQlPlugin, err = os.ReadFile(baseDir + "/integarion_type/" + plugin.Components.CloudQLBinary.PathInArchive)
183
+ // if err != nil {
184
+ // logger.Error("failed to open cloudql-plugin file", zap.Error(err), zap.String("url", plugin.Components.CloudQLBinary.URI))
185
+ // return nil, nil, fmt.Errorf("open cloudql-plugin file for url %s: %w", plugin.IntegrationType.String(), err)
186
+ // }
187
187
}
188
188
189
189
logger .Info ("integration binaries loaded" )
@@ -208,6 +208,6 @@ func ExtractIntegrationBinaries(logger *zap.Logger, plugin platformspec.PluginSp
208
208
DescriberTag : describerTags ,
209
209
DiscoveryType : discoveryType ,
210
210
Tags : tagsJsonb ,
211
- }, binaries ,
211
+ }, nil ,
212
212
nil
213
213
}
0 commit comments