Inital commit.

Author: timbrandin

README.md

@@ -0,0 +1,5 @@
+// Write your tests here!
+// Here is an example.
+Tinytest.add('example', function (test) {
+  test.equal(true, true);
+});

core-tests.js

@@ -0,0 +1,19 @@
+Package.describe({
+  name: 'pipeline:core',
+  version: '0.0.1',
+  summary: 'Build Pipeline',
+  git: 'https://github.com/MeteorPipeline/core',
+  documentation: 'README.md'
+});
+
+Package.onUse(function(api) {
+  api.use('isobuild:compiler-plugin@1.0.0');
+  api.use(['caching-compiler', 'ecmascript', 'underscore']);
+  api.addFiles('pipeline.js');
+  api.export('Pipeline');
+});
+
+Package.onTest(function(api) {
+  api.use(["tinytest", "underscore"]);
+  api.use(["pipeline:core"]);
+});

package.js

@@ -0,0 +1,95 @@
+class InputPipelineFile {
+  constructor(file) {
+    this.original = file;
+    _.extend(this, _.omit(file, 'getContentsAsString'));
+  }
+  getContentsAsString() {
+    if (!this._content) {
+      this._content = this.original.getContentsAsString(arguments);
+    }
+    return this._content;
+  }
+  setContentAsString(content) {
+    this._content = content;
+  }
+};
+
+Pipeline = class PipelineClass {
+  constructor() {
+    this.pipeline = [];
+  }
+  compileOneFile(_inputFiles) {
+    inputFiles = [];
+    for(let file of _inputFiles) {
+      inputFiles.push(new InputPipelineFile(file));
+    }
+    for(let step of this.pipeline) {
+      if (step.compileOneFile) {
+        step.compileOneFile(inputFiles);
+      }
+    }
+  }
+  processFilesForTarget(_inputFiles) {
+    inputFiles = [];
+    for(let file of _inputFiles) {
+      inputFiles.push(new InputPipelineFile(file));
+    }
+    for(let step of this.pipeline) {
+      if (step.processFilesForTarget) {
+        step.processFilesForTarget(inputFiles);
+      }
+    }
+  }
+  setDiskCacheDirectory(diskCache) {
+    let step = this.pipeline[this.pipeline.length - 1];
+    if (step && step.setDiskCacheDirectory) {
+      return step.setDiskCacheDirectory(diskCache);
+    }
+  }
+  sourceMapSize(sm) {
+    let step = this.pipeline[this.pipeline.length - 1];
+    if (step && step.sourceMapSize) {
+      return step.sourceMapSize(sm);
+    }
+  }
+  parseCompileResult(stringifiedCompileResult) {
+    let step = this.pipeline[this.pipeline.length - 1];
+    if (step && step.parseCompileResult) {
+      return step.parseCompileResult(stringifiedCompileResult);
+    }
+  }
+  stringifyCompileResult(compileResult) {
+    let step = this.pipeline[this.pipeline.length - 1];
+    if (step && step.stringifyCompileResult) {
+      return step.stringifyCompileResult(compileResult);
+    }
+  }
+  compileResultSize(compileResult) {
+    let step = this.pipeline[this.pipeline.length - 1];
+    if (step && step.compileResultSize) {
+      return step.compileResultSize(compileResult);
+    }
+  }
+  addCompileResult(inputFile, compileResult) {
+    for(let step of this.pipeline) {
+      if (step.addCompileResult) {
+        step.addCompileResult(compileResult);
+      }
+    }
+  }
+  getCacheKey(inputFile) {
+    let step = this.pipeline[this.pipeline.length - 1];
+    if (step && step.getCacheKey) {
+      return step.getCacheKey(inputFile);
+    }
+  }
+  getAbsoluteImportPath(inputFile) {
+    let step = this.pipeline[this.pipeline.length - 1];
+    if (step && step.getAbsoluteImportPath) {
+      return step.getAbsoluteImportPath(inputFile);
+    }
+  }
+  push(Compiler) {
+    this.pipeline.push(new Compiler());
+  }
+};