MDS Integration

Author: buccolo

.gitignore

@@ -0,0 +1,2 @@
+.DS_Store
+.bundle/

.rspec

@@ -0,0 +1,3 @@
+--color
+--format d
+--order rand

Gemfile

@@ -0,0 +1,28 @@
+source 'https://rubygems.org'
+
+gem 'sinatra'
+gem 'tilt', '~> 1.4.1'
+gem 'tilt-jbuilder', require: 'sinatra/jbuilder'
+gem 'endpoint_base', github: 'spree/endpoint_base'
+gem 'foreman'
+gem 'unicorn'
+gem 'nokogiri'
+gem 'httparty'
+gem 'simplecov'
+
+group :development do
+  gem 'pry'
+  gem 'shotgun'
+end
+
+group :development, :test do
+  gem 'pry-byebug'
+end
+
+group :test do
+  gem 'rspec'
+  gem 'rack-test'
+  gem 'vcr'
+  gem 'webmock'
+end
+

Gemfile.lock

@@ -0,0 +1,120 @@
+GIT
+  remote: git://github.com/spree/endpoint_base.git
+  revision: f6c1859af1175bd4e29aa36823c8b02a2bb722c2
+  specs:
+    endpoint_base (0.3)
+      activesupport
+      jbuilder
+      json
+
+GEM
+  remote: https://rubygems.org/
+  specs:
+    activesupport (4.1.0)
+      i18n (~> 0.6, >= 0.6.9)
+      json (~> 1.7, >= 1.7.7)
+      minitest (~> 5.1)
+      thread_safe (~> 0.1)
+      tzinfo (~> 1.1)
+    addressable (2.3.6)
+    byebug (2.7.0)
+      columnize (~> 0.3)
+      debugger-linecache (~> 1.2)
+    coderay (1.1.0)
+    columnize (0.8.9)
+    crack (0.4.2)
+      safe_yaml (~> 1.0.0)
+    debugger-linecache (1.2.0)
+    diff-lcs (1.2.5)
+    docile (1.1.5)
+    dotenv (0.10.0)
+    foreman (0.63.0)
+      dotenv (>= 0.7)
+      thor (>= 0.13.6)
+    httparty (0.13.1)
+      json (~> 1.8)
+      multi_xml (>= 0.5.2)
+    i18n (0.6.9)
+    jbuilder (2.0.6)
+      activesupport (>= 3.0.0, < 5)
+      multi_json (~> 1.2)
+    json (1.8.1)
+    kgio (2.9.2)
+    method_source (0.8.2)
+    mini_portile (0.5.2)
+    minitest (5.3.2)
+    multi_json (1.9.2)
+    multi_xml (0.5.5)
+    nokogiri (1.6.1)
+      mini_portile (~> 0.5.0)
+    pry (0.9.12.6)
+      coderay (~> 1.0)
+      method_source (~> 0.8)
+      slop (~> 3.4)
+    pry-byebug (1.3.2)
+      byebug (~> 2.7)
+      pry (~> 0.9.12)
+    rack (1.5.2)
+    rack-protection (1.5.2)
+      rack
+    rack-test (0.6.2)
+      rack (>= 1.0)
+    raindrops (0.13.0)
+    rspec (2.14.1)
+      rspec-core (~> 2.14.0)
+      rspec-expectations (~> 2.14.0)
+      rspec-mocks (~> 2.14.0)
+    rspec-core (2.14.8)
+    rspec-expectations (2.14.5)
+      diff-lcs (>= 1.1.3, < 2.0)
+    rspec-mocks (2.14.6)
+    safe_yaml (1.0.3)
+    shotgun (0.9)
+      rack (>= 1.0)
+    simplecov (0.9.0)
+      docile (~> 1.1.0)
+      multi_json
+      simplecov-html (~> 0.8.0)
+    simplecov-html (0.8.0)
+    sinatra (1.4.4)
+      rack (~> 1.4)
+      rack-protection (~> 1.4)
+      tilt (~> 1.3, >= 1.3.4)
+    slop (3.5.0)
+    thor (0.18.1)
+    thread_safe (0.3.3)
+    tilt (1.4.1)
+    tilt-jbuilder (0.5.2)
+      jbuilder
+      tilt
+    tzinfo (1.1.0)
+      thread_safe (~> 0.1)
+    unicorn (4.8.2)
+      kgio (~> 2.6)
+      rack
+      raindrops (~> 0.7)
+    vcr (2.6.0)
+    webmock (1.18.0)
+      addressable (>= 2.3.6)
+      crack (>= 0.3.2)
+
+PLATFORMS
+  ruby
+
+DEPENDENCIES
+  endpoint_base!
+  foreman
+  httparty
+  nokogiri
+  pry
+  pry-byebug
+  rack-test
+  rspec
+  shotgun
+  simplecov
+  sinatra
+  tilt (~> 1.4.1)
+  tilt-jbuilder
+  unicorn
+  vcr
+  webmock

Procfile

@@ -0,0 +1 @@
+web: bundle exec unicorn -p $PORT -c ./config/unicorn.rb

README.md

@@ -0,0 +1,20 @@
+# MDS Fulfillment Integration
+
+This integration is designed to integrate Wombat with
+[MDS Fulfillment](http://www.mdsfulfillment.com/) API.
+
+This is a fully hosted and supported integration for use with the [Wombat](http://wombat.co)
+product. With this integration you can perform the following functions:
+
+* Push Orders to MDS Fulfillment
+* Get Inventory stock / status from MDS Fulfillment
+* Get Orders / Shipment updates from MDS Fulfillment
+
+[Wombat](http://wombat.co) allows you to connect to your own custom integrations.
+Feel free to modify the source code and host your own version of the integration
+or better yet, help to make the official integration better by submitting a pull request!
+
+![Wombat Logo](http://spreecommerce.com/images/wombat_logo.png)
+
+This integration is 100% open source an licensed under the terms of the New BSD License.
+

config.ru

@@ -0,0 +1,6 @@
+require 'rubygems'
+require 'bundler/setup'
+
+Bundler.require(:default)
+require './mds_integration'
+run MDSIntegration

config/unicorn.rb

@@ -0,0 +1,28 @@
+worker_processes ENV.fetch('WORKER_PROCESSES', 5).to_i
+timeout 180
+
+preload_app true
+
+GC.respond_to?(:copy_on_write_friendly=) and  GC.copy_on_write_friendly = true
+
+before_fork do |server, worker|
+  defined?(ActiveRecord::Base) and ActiveRecord::Base.connection.disconnect!
+
+  # kills old children after zero downtime deploy
+  old_pid = "#{server.config[:pid]}.oldbin"
+  if old_pid != server.pid
+    begin
+      sig = (worker.nr + 1) >= server.worker_processes ? :QUIT : :TTOU
+      Process.kill(sig, File.read(old_pid).to_i)
+    rescue Errno::ENOENT, Errno::ESRCH
+    end
+  end
+
+  sleep 1
+end
+
+after_fork do |server, worker|
+  defined?(ActiveRecord::Base) and ActiveRecord::Base.establish_connection
+
+  defined?(Rails) and Rails.cache.respond_to?(:reconnect) and Rails.cache.reconnect
+end

lib/mds/mds.rb

@@ -0,0 +1,10 @@
+# services
+require_relative 'services/base'
+require_relative 'services/full_inventory'
+require_relative 'services/submit_order'
+require_relative 'services/shipping_status/tracking'
+
+# responses
+require_relative 'responses/cust_order_ack'
+require_relative 'responses/sku_full_ack'
+require_relative 'responses/shipping_sku_ack'

lib/mds/responses/cust_order_ack.rb

@@ -0,0 +1,23 @@
+module MDS
+  module Responses
+    class CUSTOrderAck
+      attr_accessor :body
+
+      def initialize(body)
+        @body = body
+      end
+
+      def success?
+        body["OrderAck"]["Result"] == "1"
+      end
+
+      def message
+        if success?
+          "#{body["OrderAck"]["OrderID"]} was received by MDS Fulfillment."
+        else
+          body["OrderAck"]["Message"]
+        end
+      end
+    end
+  end
+end

lib/mds/responses/shipping_sku_ack.rb

@@ -0,0 +1,30 @@
+module MDS
+  module Responses
+    class ShippingSKUAck
+      attr_accessor :body
+
+      def initialize(body)
+        @body = body.to_h
+      end
+
+      def success?
+        true
+      end
+
+      def message
+        "#{objects.size} shipments were received."
+      end
+
+      def objects
+        Array(body["Order"]).map do |order|
+          {
+            id: order["OrderID"],
+            status: "shipped",
+            tracking: order["TrackingNumber"],
+            shipped_at: DateTime.parse(order["OrderShipDate"])
+          }
+        end
+      end
+    end
+  end
+end

lib/mds/responses/sku_full_ack.rb

@@ -0,0 +1,35 @@
+module MDS
+  module Responses
+    class SKUFullAck
+      attr_accessor :body
+
+      def initialize(body)
+        @body = body.to_h
+      end
+
+      def success?
+        true
+      end
+
+      def message
+        "Inventory for #{objects.size} products was received."
+      end
+
+      def objects
+        sku_lines.map do |sku_line|
+          {
+            id: sku_line["SKU"],
+            location: "MDS",
+            product_id: sku_line["SKU"],
+            quantity: sku_line["OnHand"].to_i
+          }
+        end
+      end
+
+      private
+      def sku_lines
+        Array(body["SKULine"]).reject {|sku_line| sku_line["Active"] != "Y"}
+      end
+    end
+  end
+end

lib/mds/services/base.rb

@@ -0,0 +1,51 @@
+module MDS
+  module Services
+    module Base
+      def self.included(base)
+        base.send(:extend, ClassMethods)
+      end
+
+      module ClassMethods
+        attr_reader :url_package, :xml_root
+
+        def set_url_package(package)
+          @url_package = package
+        end
+
+        def set_xml_root(xml_root)
+          @xml_root = xml_root
+        end
+      end
+
+      def initialize(credentials)
+        @client_code = credentials.fetch(:client_code)
+        @client_signature = credentials.fetch(:client_signature)
+      end
+
+      def query(object = {})
+        puts payload = builder(object).to_xml
+        puts '-' * 77
+        puts xml_response = HTTParty.get("http://webservice-dev.mdsfulfillment.com/#{self.class.url_package}/ReceiveXML.aspx?xml=" + URI.encode(payload))
+        build_response_instance(xml_response)
+      end
+
+      def build_response_instance(xml_response)
+        response = Hash.from_xml(xml_response)
+        klass    = response.keys[0]
+        body     = response[klass]
+
+        MDS::Responses.const_get(klass).new(body)
+      end
+
+      def xml_builder
+        Nokogiri::XML::Builder.new do |xml|
+          xml.send(self.class.xml_root, 'xml:lang' => 'en-US') do
+            xml.ClientCode @client_code
+            xml.ClientSignature @client_signature
+            yield(xml)
+          end
+        end
+      end
+    end
+  end
+end

lib/mds/services/full_inventory.rb

@@ -0,0 +1,16 @@
+module MDS
+  module Services
+    class FullInventory
+      include Base
+
+      set_xml_root    'MDSFullSKU'
+      set_url_package 'mds.full.inventory'
+
+      def builder(_)
+        xml_builder do |xml|
+          xml.SKUDetail 'True'
+        end
+      end
+    end
+  end
+end