commit 967c867745e53ae3731acde1892f0102f5f7cc07 Author: richie Date: Mon Jun 15 16:52:55 2020 +0800 S3文件服务器 diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..29c9cac --- /dev/null +++ b/.gitignore @@ -0,0 +1,10 @@ +*.iml +.idea/ +lib/report/*.jar +target/ +.DS_Store +.gradle +build +local.properties +classes/ +transform-classes/ \ No newline at end of file diff --git a/build.gradle b/build.gradle new file mode 100644 index 0000000..c56b872 --- /dev/null +++ b/build.gradle @@ -0,0 +1,122 @@ + +apply plugin: 'java' + + +ext { + /** + * 项目中依赖的jar的路径 + * 1.如果依赖的jar需要打包到zip中,放置在lib根目录下 + * 2.如果依赖的jar仅仅是编译时需要，防止在lib下子目录下即可 + */ + libPath = "$projectDir/../webroot/WEB-INF/lib" + + /** + * 是否对插件的class进行加密保护，防止反编译 + */ + guard = false + + def pluginInfo = getPluginInfo() + pluginPre = "fine-plugin" + pluginName = pluginInfo.id + pluginVersion = pluginInfo.version + + outputPath = "$projectDir/../webroot/WEB-INF/plugins/plugin-" + pluginName + "-1.0/classes" +} + +group = 'com.fr.plugin' +version = '10.0' +sourceCompatibility = '8' + +sourceSets { + main { + java.outputDir = file(outputPath) + output.resourcesDir = file(outputPath) + } +} + +ant.importBuild("encrypt.xml") +//定义ant变量 +ant.projectDir = projectDir +ant.references["compile.classpath"] = ant.path { + fileset(dir: libPath, includes: '**/*.jar') + fileset(dir: ".",includes:"**/*.jar" ) +} + +classes.dependsOn('clean') + +task copyFiles(type: Copy,dependsOn: 'classes'){ + from outputPath + into "$projectDir/classes" +} + +task preJar(type:Copy,dependsOn: guard ? 'compile_encrypt_javas' : 'compile_plain_javas'){ + from "$projectDir/classes" + into "$projectDir/transform-classes" + include "**/*.*" +} +jar.dependsOn("preJar") + +task makeJar(type: Jar,dependsOn: preJar){ + from fileTree(dir: "$projectDir/transform-classes") + baseName pluginPre + appendix pluginName + version pluginVersion + destinationDir = file("$buildDir/libs") + + doLast(){ + delete file("$projectDir/classes") + delete file("$projectDir/transform-classes") + } +} + +task copyFile(type: Copy,dependsOn: ["makeJar"]){ + from "$buildDir/libs" + from("$projectDir/lib") { + include "*.jar" + } + from "$projectDir/plugin.xml" + into file("$buildDir/temp/plugin") +} + +task zip(type:Zip,dependsOn:["copyFile"]){ + from "$buildDir/temp/plugin" + destinationDir file("$buildDir/install") + baseName pluginPre + appendix pluginName + version pluginVersion +} + +//控制build时包含哪些文件,排除哪些文件 +processResources { +// exclude everything +// 用*.css没效果 +// exclude '**/*.css' +// except this file +// include 'xx.xml' +} + +/*读取plugin.xml中的version*/ +def getPluginInfo(){ + def xmlFile = file("plugin.xml") + if (!xmlFile.exists()) { + return ["id":"none", "version":"1.0.0"] + } + def plugin = new XmlParser().parse(xmlFile) + def version = plugin.version[0].text() + def id = plugin.id[0].text() + return ["id":id,"version":version] +} + +repositories { + mavenLocal() + maven { + url = uri('http://mvn.finedevelop.com/repository/maven-public/') + } +} + +dependencies { + //使用本地jar + implementation fileTree(dir: 'lib', include: ['**/*.jar']) + implementation fileTree(dir: libPath, include: ['**/*.jar']) +} + diff --git a/encrypt.xml b/encrypt.xml new file mode 100644 index 0000000..15c436f --- /dev/null +++ b/encrypt.xml @@ -0,0 +1,10 @@ + + + + + + + + + + \ No newline at end of file diff --git a/lib/aws-java-sdk-core-1.11.801.jar b/lib/aws-java-sdk-core-1.11.801.jar new file mode 100644 index 0000000..3f315de Binary files /dev/null and b/lib/aws-java-sdk-core-1.11.801.jar differ diff --git a/lib/aws-java-sdk-kms-1.11.801.jar b/lib/aws-java-sdk-kms-1.11.801.jar new file mode 100644 index 0000000..895fa9d Binary files /dev/null and b/lib/aws-java-sdk-kms-1.11.801.jar differ diff --git a/lib/aws-java-sdk-s3-1.11.801.jar b/lib/aws-java-sdk-s3-1.11.801.jar new file mode 100644 index 0000000..99a7533 Binary files /dev/null and b/lib/aws-java-sdk-s3-1.11.801.jar differ diff --git a/lib/commons-codec-1.11.jar b/lib/commons-codec-1.11.jar new file mode 100644 index 0000000..2245120 Binary files /dev/null and b/lib/commons-codec-1.11.jar differ diff --git a/lib/commons-logging-1.2.jar b/lib/commons-logging-1.2.jar new file mode 100644 index 0000000..93a3b9f Binary files /dev/null and b/lib/commons-logging-1.2.jar differ diff --git a/lib/finekit-10.0.jar b/lib/finekit-10.0.jar new file mode 100644 index 0000000..4b0a020 Binary files /dev/null and b/lib/finekit-10.0.jar differ diff --git a/lib/httpclient-4.5.9.jar b/lib/httpclient-4.5.9.jar new file mode 100644 index 0000000..83bc29d Binary files /dev/null and b/lib/httpclient-4.5.9.jar differ diff --git a/lib/httpcore-4.4.11.jar b/lib/httpcore-4.4.11.jar new file mode 100644 index 0000000..c31d401 Binary files /dev/null and b/lib/httpcore-4.4.11.jar differ diff --git a/lib/ion-java-1.0.2.jar b/lib/ion-java-1.0.2.jar new file mode 100644 index 0000000..192a98e Binary files /dev/null and b/lib/ion-java-1.0.2.jar differ diff --git a/lib/jackson-annotations-2.6.0.jar b/lib/jackson-annotations-2.6.0.jar new file mode 100644 index 0000000..0a18c34 Binary files /dev/null and b/lib/jackson-annotations-2.6.0.jar differ diff --git a/lib/jackson-core-2.6.7.jar b/lib/jackson-core-2.6.7.jar new file mode 100644 index 0000000..d195e85 Binary files /dev/null and b/lib/jackson-core-2.6.7.jar differ diff --git a/lib/jackson-databind-2.6.7.3.jar b/lib/jackson-databind-2.6.7.3.jar new file mode 100644 index 0000000..ef519d3 Binary files /dev/null and b/lib/jackson-databind-2.6.7.3.jar differ diff --git a/lib/jackson-dataformat-cbor-2.6.7.jar b/lib/jackson-dataformat-cbor-2.6.7.jar new file mode 100644 index 0000000..f008744 Binary files /dev/null and b/lib/jackson-dataformat-cbor-2.6.7.jar differ diff --git a/lib/jmespath-java-1.11.801.jar b/lib/jmespath-java-1.11.801.jar new file mode 100644 index 0000000..d4f622c Binary files /dev/null and b/lib/jmespath-java-1.11.801.jar differ diff --git a/lib/joda-time-2.8.1.jar b/lib/joda-time-2.8.1.jar new file mode 100644 index 0000000..94be659 Binary files /dev/null and b/lib/joda-time-2.8.1.jar differ diff --git a/plugin.xml b/plugin.xml new file mode 100644 index 0000000..3217a81 --- /dev/null +++ b/plugin.xml @@ -0,0 +1,27 @@ + + + com.fanruan.fs.s3.repository + + com.fanruan.fs + yes + no + 1.0 + 10.0 + 2020-01-27 + richie + + + ]]> + + + + + + + + + + + + diff --git a/readme.md b/readme.md new file mode 100644 index 0000000..914aad6 --- /dev/null +++ b/readme.md @@ -0,0 +1,3 @@ +# 文件服务器（S3协议） + +能够使用支持S3协议的云存储，作为文件服务器 \ No newline at end of file diff --git a/src/main/java/com/fanruan/fs/s3/repository/S3FactoryProvider.java b/src/main/java/com/fanruan/fs/s3/repository/S3FactoryProvider.java new file mode 100644 index 0000000..66fd1e9 --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/S3FactoryProvider.java @@ -0,0 +1,25 @@ +package com.fanruan.fs.s3.repository; + +import com.fr.intelli.record.Focus; +import com.fr.io.base.provider.RepositoryFactoryProvider; +import com.fr.io.fun.AbstractRepositoryFactoryProvider; +import com.fanruan.fs.s3.repository.core.S3Config; +import com.fanruan.fs.s3.repository.core.S3RepositoryFactory; +import com.fr.record.analyzer.EnableMetrics; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +@EnableMetrics +public class S3FactoryProvider extends AbstractRepositoryFactoryProvider { + + private static final S3RepositoryFactory factory = new S3RepositoryFactory(); + + @Override + @Focus(id="com.fanruan.fs.s3.repository", text="") + public RepositoryFactoryProvider getFactory() { + return factory; + } +} diff --git a/src/main/java/com/fanruan/fs/s3/repository/S3FileServerResource.java b/src/main/java/com/fanruan/fs/s3/repository/S3FileServerResource.java new file mode 100644 index 0000000..100586d --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/S3FileServerResource.java @@ -0,0 +1,25 @@ +package com.fanruan.fs.s3.repository; + +import com.fr.decision.fun.impl.AbstractWebResourceProvider; +import com.fr.decision.web.MainComponent; +import com.fanruan.fs.s3.repository.web.S3FileServerComponent; +import com.fr.web.struct.Atom; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +public class S3FileServerResource extends AbstractWebResourceProvider { + + @Override + public Atom attach() { + return MainComponent.KEY; + } + + @Override + public Atom client() { + return S3FileServerComponent.KEY; + } + +} diff --git a/src/main/java/com/fanruan/fs/s3/repository/S3LocaleFinder.java b/src/main/java/com/fanruan/fs/s3/repository/S3LocaleFinder.java new file mode 100644 index 0000000..b4b929b --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/S3LocaleFinder.java @@ -0,0 +1,15 @@ +package com.fanruan.fs.s3.repository; + +import com.fr.stable.fun.impl.AbstractLocaleFinder; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +public class S3LocaleFinder extends AbstractLocaleFinder { + @Override + public String find() { + return "com/fanruan/fs/s3/repository/locale/s3"; + } +} diff --git a/src/main/java/com/fanruan/fs/s3/repository/core/S3Config.java b/src/main/java/com/fanruan/fs/s3/repository/core/S3Config.java new file mode 100644 index 0000000..c730d1f --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/core/S3Config.java @@ -0,0 +1,73 @@ +package com.fanruan.fs.s3.repository.core; + +import com.fr.config.Identifier; +import com.fr.config.holder.Conf; +import com.fr.config.holder.factory.Holders; +import com.fr.io.config.CommonRepoConfig; +import com.fr.stable.StringUtils; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +public class S3Config extends CommonRepoConfig { + + public S3Config() { + super(S3RepositoryFactory.IDENTITY); + } + + @Identifier("endPoint") + private Conf endPoint = Holders.simple(StringUtils.EMPTY); + + @Identifier("accessKeyId") + private Conf accessKeyId = Holders.simple(StringUtils.EMPTY); + + @Identifier("accessKeySecret") + private Conf accessKeySecret = Holders.simple(StringUtils.EMPTY); + + @Identifier("bucket") + private Conf bucket = Holders.simple(StringUtils.EMPTY); + + public String getEndPoint() { + return endPoint.get(); + } + + public void setEndPoint(String endPoint) { + this.endPoint.set(endPoint); + } + + public String getAccessKeyId() { + return accessKeyId.get(); + } + + public void setAccessKeyId(String accessKeyId) { + this.accessKeyId.set(accessKeyId); + } + + public String getAccessKeySecret() { + return accessKeySecret.get(); + } + + public void setAccessKeySecret(String accessKeySecret) { + this.accessKeySecret.set(accessKeySecret); + } + + public String getBucket() { + return bucket.get(); + } + + public void setBucket(String bucket) { + this.bucket.set(bucket); + } + + @Override + public S3Config clone() throws CloneNotSupportedException { + S3Config cloned = (S3Config) super.clone(); + cloned.endPoint = (Conf) endPoint.clone(); + cloned.accessKeyId = (Conf) accessKeyId.clone(); + cloned.accessKeySecret = (Conf) accessKeySecret.clone(); + cloned.bucket = (Conf) bucket.clone(); + return cloned; + } +} diff --git a/src/main/java/com/fanruan/fs/s3/repository/core/S3RepositoryFactory.java b/src/main/java/com/fanruan/fs/s3/repository/core/S3RepositoryFactory.java new file mode 100644 index 0000000..8e37055 --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/core/S3RepositoryFactory.java @@ -0,0 +1,39 @@ +package com.fanruan.fs.s3.repository.core; + +import com.fr.io.base.provider.impl.ConfigRepositoryFactory; +import com.fr.io.context.info.RepositoryProfile; +import com.fr.io.repository.ResourceRepository; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +public class S3RepositoryFactory extends ConfigRepositoryFactory { + + static final String IDENTITY = "S3"; + + public S3RepositoryFactory() { + super(IDENTITY); + } + + @Override + public Class> getProfileClass() { + return S3RepositoryProfile.class; + } + + @Override + public Class getConfigClass() { + return S3Config.class; + } + + @Override + public boolean verifyConfig(S3Config s3Config) { + return false; + } + + @Override + public ResourceRepository produce(String repoName, String workRoot, S3Config config) { + return new S3ResourceRepository(repoName, workRoot, null, null); + } +} diff --git a/src/main/java/com/fanruan/fs/s3/repository/core/S3RepositoryProfile.java b/src/main/java/com/fanruan/fs/s3/repository/core/S3RepositoryProfile.java new file mode 100644 index 0000000..6331dfb --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/core/S3RepositoryProfile.java @@ -0,0 +1,39 @@ +package com.fanruan.fs.s3.repository.core; + +import com.fr.config.Identifier; +import com.fr.config.holder.Conf; +import com.fr.config.holder.factory.Holders; +import com.fr.io.context.info.RepositoryProfile; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +public class S3RepositoryProfile extends RepositoryProfile { + + public S3RepositoryProfile() { + + } + + @Identifier("s3Config") + private Conf s3Config = Holders.obj(null, S3Config.class); + + + @Override + public S3Config getConfig() { + return s3Config.get(); + } + + @Override + public void setConfig(S3Config s3Config) { + this.s3Config.set(s3Config); + } + + @Override + public RepositoryProfile clone() throws CloneNotSupportedException { + S3RepositoryProfile cloned = (S3RepositoryProfile) super.clone(); + cloned.s3Config = (Conf) s3Config.clone(); + return cloned; + } +} diff --git a/src/main/java/com/fanruan/fs/s3/repository/core/S3ResourceRepository.java b/src/main/java/com/fanruan/fs/s3/repository/core/S3ResourceRepository.java new file mode 100644 index 0000000..a678390 --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/core/S3ResourceRepository.java @@ -0,0 +1,115 @@ +package com.fanruan.fs.s3.repository.core; + +import com.amazonaws.services.s3.AmazonS3; +import com.fanruan.api.log.LogKit; +import com.fr.io.repository.FineFileEntry; +import com.fr.io.repository.base.BaseResourceRepository; +import com.fr.stable.Filter; +import com.fr.workspace.resource.ResourceIOException; + +import java.io.InputStream; +import java.net.URL; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +public class S3ResourceRepository extends BaseResourceRepository { + + private AmazonS3 s3; + private String bucket; + + public S3ResourceRepository(String repoName, String workRoot, AmazonS3 s3, String bucket) { + super(repoName, workRoot); + this.s3 = s3; + this.bucket = bucket; + } + + + @Override + public String getSeparator() { + return "/"; + } + + @Override + public FineFileEntry getEntry(String path) { + return null; + } + + @Override + public FineFileEntry[] listEntry(String dir) { + return new FineFileEntry[0]; + } + + @Override + public URL getResource(String path) { + return null; + } + + @Override + public InputStream read(String filePath) throws ResourceIOException { + return null; + } + + @Override + public void write(String path, byte[] data) { + + } + + @Override + public boolean createFile(String path) { + return false; + } + + @Override + public boolean createDirectory(String path) { + return false; + } + + @Override + public boolean delete(String path) { + try { + s3.deleteObject(bucket, path); + } catch (Exception e) { + LogKit.error(e.getMessage(), e); + return false; + } + return true; + } + + @Override + public boolean exist(String path) { + return s3.getObject(bucket, path) != null; + } + + @Override + public String[] list(String dir, final Filter filter) { + return new String[0]; + } + + @Override + public boolean isDirectory(String path) { + return false; + } + + @Override + public long lastModified(String path) { + return s3.getObject(bucket, path).getObjectMetadata().getLastModified().getTime(); + } + + @Override + public long length(String path) { + return s3.getObject(bucket, path).getObjectMetadata().getContentLength(); + } + + @Override + public void shutDown() { + s3.shutdown(); + } + + @Override + public String getIdentity() { + return S3RepositoryFactory.IDENTITY; + } +} diff --git a/src/main/java/com/fanruan/fs/s3/repository/web/S3FileServerComponent.java b/src/main/java/com/fanruan/fs/s3/repository/web/S3FileServerComponent.java new file mode 100644 index 0000000..890c2c7 --- /dev/null +++ b/src/main/java/com/fanruan/fs/s3/repository/web/S3FileServerComponent.java @@ -0,0 +1,25 @@ +package com.fanruan.fs.s3.repository.web; + +import com.fr.web.struct.Component; +import com.fr.web.struct.browser.RequestClient; +import com.fr.web.struct.category.ScriptPath; + +/** + * @author richie + * @version 10.0 + * Created by richie on 2020/6/15 + */ +public class S3FileServerComponent extends Component { + + public static S3FileServerComponent KEY = new S3FileServerComponent(); + + private S3FileServerComponent() { + + } + + @Override + public ScriptPath script(RequestClient req) { + return ScriptPath.build("com/fanruan/fs/s3/repository/web/js/bundle.js"); + } + +} diff --git a/src/main/resources/com/fanruan/fs/s3/repository/locale/s3.properties b/src/main/resources/com/fanruan/fs/s3/repository/locale/s3.properties new file mode 100644 index 0000000..9b85aab --- /dev/null +++ b/src/main/resources/com/fanruan/fs/s3/repository/locale/s3.properties @@ -0,0 +1,5 @@ +Plugin-S3_Input=Please Input +Plugin-S3_End_Point=Endpoint +Plugin-S3_Access_Key_Id=AccessKeyId +Plugin-S3_Access_Key_Secret=AccessKeySecret +Plugin-S3_Bucket=Bucket \ No newline at end of file diff --git a/src/main/resources/com/fanruan/fs/s3/repository/locale/s3_en_US.properties b/src/main/resources/com/fanruan/fs/s3/repository/locale/s3_en_US.properties new file mode 100644 index 0000000..9b85aab --- /dev/null +++ b/src/main/resources/com/fanruan/fs/s3/repository/locale/s3_en_US.properties @@ -0,0 +1,5 @@ +Plugin-S3_Input=Please Input +Plugin-S3_End_Point=Endpoint +Plugin-S3_Access_Key_Id=AccessKeyId +Plugin-S3_Access_Key_Secret=AccessKeySecret +Plugin-S3_Bucket=Bucket \ No newline at end of file diff --git a/src/main/resources/com/fanruan/fs/s3/repository/locale/s3_zh_CN.properties b/src/main/resources/com/fanruan/fs/s3/repository/locale/s3_zh_CN.properties new file mode 100644 index 0000000..359d304 --- /dev/null +++ b/src/main/resources/com/fanruan/fs/s3/repository/locale/s3_zh_CN.properties @@ -0,0 +1,5 @@ +Plugin-S3_Input=\u8BF7\u8F93\u5165 +Plugin-S3_End_Point=Endpoint +Plugin-S3_Access_Key_Id=AccessKeyId +Plugin-S3_Access_Key_Secret=AccessKeySecret +Plugin-S3_Bucket=Bucket \ No newline at end of file diff --git a/src/main/resources/com/fanruan/fs/s3/repository/web/js/bundle.js b/src/main/resources/com/fanruan/fs/s3/repository/web/js/bundle.js new file mode 100644 index 0000000..7cbcdf5 --- /dev/null +++ b/src/main/resources/com/fanruan/fs/s3/repository/web/js/bundle.js @@ -0,0 +1,154 @@ +BI.config("dec.constant.intelligence.cluster.file.server", function (items) { + items.push({ + value: "S3", // 地址栏显示的hash值 + id: "decision-intelligence-cluster-file-s3", // id + text: BI.i18nText(""), // 文字 + cardType: "dec.intelligence.cluster.file.s3" + }); + return items; +}); + + +!(function () { + var LABEL_WIDTH = 116, EDITOR_WIDTH = 300; + var S3 = BI.inherit(BI.Widget, { + + props: { + baseCls: "dec-cluster-ftp", + value: {} + }, + + _store: function () { + return BI.Models.getModel("dec.model.intelligence.cluster.file.s3", { + value: this.options.value + }); + }, + + watch: {}, + + render: function () { + var self = this, o = this.options; + return { + type: "bi.vertical", + tgap: 15, + items: [ + { + type: "dec.label.editor.item", + textWidth: LABEL_WIDTH, + editorWidth: EDITOR_WIDTH, + watermark: BI.i18nText("Plugin-S3_Input"), + text: BI.i18nText("Plugin-S3_End_Point"), + value: this.model.endPoint, + ref: function (_ref) { + self.endPointRow = _ref; + }, + listeners: [{ + eventName: BI.Editor.EVENT_CHANGE, + action: function () { + self.store.setEndPoint(this.getValue()); + } + }] + }, { + type: "dec.label.editor.item", + textWidth: LABEL_WIDTH, + editorWidth: EDITOR_WIDTH, + watermark: BI.i18nText("Plugin-S3_Input"), + text: BI.i18nText("Plugin-S3_Access_Key_Id"), + value: this.model.port, + ref: function (_ref) { + self.portRow = _ref; + }, + listeners: [{ + eventName: BI.Editor.EVENT_CHANGE, + action: function () { + self.store.setAccessKeyId(this.getValue()); + } + }] + }, + { + type: "dec.label.editor.item", + textWidth: LABEL_WIDTH, + editorWidth: EDITOR_WIDTH, + watermark: BI.i18nText("Plugin-S3_Access_Key_Secret"), + text: BI.i18nText("Plugin-S3_Access_Key_Secret"), + value: this.model.accessKeySecret, + listeners: [{ + eventName: BI.Editor.EVENT_CHANGE, + action: function () { + self.store.setAccessKeySecret(this.getValue()); + } + }] + }, + { + type: "dec.label.editor.item", + textWidth: LABEL_WIDTH, + editorWidth: EDITOR_WIDTH, + watermark: BI.i18nText("Plugin-S3_Bucket"), + text: BI.i18nText("Plugin-S3_Bucket"), + value: this.model.bucket, + listeners: [{ + eventName: BI.Editor.EVENT_CHANGE, + action: function () { + self.store.setBucket(this.getValue()); + } + }] + }] + }; + }, + + getValue: function () { + return { + endPoint: this.model.endPoint, + accessKeyId: this.model.accessKeyId, + accessKeySecret: this.model.accessKeySecret, + bucket: this.model.bucket + }; + }, + + }); + BI.shortcut("dec.intelligence.cluster.file.s3", S3); +})(); + + +!(function () { + var Model = BI.inherit(Fix.Model, { + + state: function () { + var val = this.options.value; + return { + endPoint: val.endPoint, + accessKeyId: val.accessKeyId, + accessKeySecret: val.accessKeySecret, + bucket: val.bucket + }; + }, + + computed: { + encodingArray: function () { + return BI.map(DecCst.EncodeConstants.ENCODING_ARRAY, function (i, v) { + return { + value: v + }; + }); + } + }, + + actions: { + setEndPoint: function (v) { + this.model.endPoint = v; + }, + + setAccessKeyId: function (v) { + this.model.accessKeyId = v; + }, + + setAccessKeySecret: function (v) { + this.model.accessKeySecret = v; + }, + setBucket: function (v) { + this.model.bucket = v; + } + } + }); + BI.model("dec.model.intelligence.cluster.file.s3", Model); +})(); \ No newline at end of file