Upgrade version

Update hastebin urls

.bundle/config

@@ -0,0 +1,3 @@
+---
+BUNDLE_RETRY: "3"
+BUNDLE_JOBS: "4"

.github/CODEOWNERS

@@ -0,0 +1 @@
+* @toptal/marketing-tools-2-eng

.github/pull_request_template.md

@@ -0,0 +1,33 @@
+[ABC-1234](https://toptal-core.atlassian.net/browse/ABC-1234)
+
+### Description
+
+Describe the changes and motivations for the pull request, unless obvious from the title.
+
+[Designs](https://share.abstract.com) (if applicable)
+
+### How to test
+
+- `bundle install`
+- FIXME: Add the steps describing how to test your changes manually
+
+### Environment variables
+
+Include a snapshot of the ENV vars used in your local env when this PR was created.
+
+```
+PUBLIC_ENV_VAR=public-value
+GLOBAL_SECRET_ENV_VAR=xxx # Added in 1Password in Shared-Utilities-Environment group
+OWN_PRIVATE_ENV_VAR # Different for everyone
+```
+
+### Acceptance Criteria
+
+- [ ] Add acceptance criterias from Jira task [ABC-1234]
+
+### Pre-merge checklist
+
+- [ ] The PR relates to a single subject with a clear title and description in grammatically correct, complete sentences.
+- [ ] Verify that feature branch is up-to-date with `master` (if not - rebase it).
+- [ ] Double check the quality of [commit messages](http://chris.beams.io/posts/git-commit/).
+- [ ] A snapshot of the author's env vars has been added

.github/workflows/close-inactive.yaml

@@ -0,0 +1,30 @@
+name: Close inactive issues and PRs
+on:
+  workflow_dispatch:
+  schedule:
+    - cron: "30 1 * * *"
+
+jobs:
+  close-stale:
+    runs-on: ubuntu-latest
+    permissions:
+      issues: write
+      pull-requests: write
+    steps:
+      - uses: actions/stale@v6
+        with:
+          days-before-stale: 30
+          days-before-close: 14
+          stale-issue-label: "stale"
+          stale-pr-label: "stale"
+
+          exempt-issue-labels: backlog,triage,nostale
+          exempt-pr-labels: backlog,triage,nostale
+
+          stale-pr-message: "This PR is stale because it has been open for 30 days with no activity."
+          close-pr-message: "This PR was closed because it has been inactive for 14 days since being marked as stale."
+
+          stale-issue-message: "This issue is stale because it has been open for 30 days with no activity."
+          close-issue-message: "This issue was closed because it has been inactive for 14 days since being marked as stale."
+
+          repo-token: ${{ secrets.GITHUB_TOKEN }}

.github/workflows/unit.yml

@@ -0,0 +1,27 @@
+name: Unit
+
+on:
+  push:
+    branches: [master]
+  pull_request:
+
+jobs:
+  unit_tests:
+    name: Unit tests
+    runs-on: ubuntu-latest
+    timeout-minutes: 5
+
+    steps:
+    - uses: actions/checkout@v3
+    - uses: ruby/setup-ruby@v1
+      with:
+        ruby-version: '3.0' 
+        bundler-cache: true
+
+    - name: Run bundle install
+      run: |
+        gem install bundler
+        bundle install --jobs 4 --retry 3
+
+    - name: Build and test with rspec
+      run: bundle exec rspec spec

.gitignore

@@ -1,3 +1,6 @@
 *.swp
 *.swo
 *.gem
+Gemfile.lock
+.rspec
+.DS_STORE

.travis.yml

@@ -0,0 +1,9 @@
+script: "rspec spec"
+branches:
+  only:
+    - master
+rvm:
+  - 1.8.7
+  - 1.9.3
+  - 2.0.0
+  - 2.4.0

Gemfile

@@ -0,0 +1,2 @@
+source 'https://rubygems.org'
+gemspec

LICENSE.txt

@@ -0,0 +1,8 @@
+Copyright 2022 Toptal LLC
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+

README.md

@@ -1,54 +1,134 @@
 # Haste Client
 
-haste-client is a simple client for uploading data to haste-server.  All you do it pipe data in STDIN:
+Haste-client is a simple client for uploading data to `Haste` server.  All you need to do is to pipe data in STDIN:
 
-`cat file | haste`
+`cat file | HASTE_SERVER_TOKEN=mytoken haste`
 
-And once the output makes it to the server, it will print the URL to STDOUT.
+And once the output makes it to the server, it will print the `Haste` share page URL to STDOUT.
 
-This can be really really cool in combination with `pbcopy`, like:
+This can be combined with `pbcopy`, like:
 
-* mac osx: `cat file | haste | pbcopy` 
+* mac osx: `cat file | haste | pbcopy`
 * linux: `cat file | haste | xsel`
 
 after which the contents of `file` will be accessible at a URL which has been copied to your pasteboard.
 
-## Making uploading file contents easier
-
-If you supply a valid file path as argument #1 to the client, it will be uploaded:
+## Installation
 
 ``` bash
-# equivelant
+gem install haste
+```
+
+## Configuration
+
+Most of the configuration is controlled by env variables. Here is the all environment variables that you can use.
+
+```
+HASTE_SERVER: Haste server domain url
+HASTE_SERVER_TOKEN: Github authentication token
+HASTE_SHARE_SERVER: Haste share server domain url
+HASTE_USER: Basic authentication user name
+HASTE_PASS: Basic authentication user pass
+HASTE_SSL_CERTS: SSL certs path
+```
+
+To add these environment variables, you should simply add them to your ~.bash_profile:
+
+```bash
+export VARIABLE="value"
+```
+
+### Authentication
+
+If you are using default `HASTE_SERVER`, you need to have an GitHub authentication token.
+You can get the information about authentication and how to generate token [here](https://www.toptal.com/developers/hastebin/documentation)
+
+After you have generated your token, you should add it to your ~.bash_profile:
+
+```bash
+export HASTE_SERVER_TOKEN="mytoken"
+```
+
+or you can add token to your command:
+
+```bash
+cat file | HASTE_SERVER_TOKEN=mytoken haste`
+```
+
+If your `Haste` installation requires http authentication, add the following to your ~.bash_profile:
+
+```bash
+export HASTE_USER="myusername"
+export HASTE_PASS="mypassword"
+```
+
+if you are using SSL, you will need to supply your certs path
+
+```bash
+export HASTE_SSL_CERTS="/System/Library/OpenSSL/certs"
+```
+
+## Usage
+
+If you supply a valid file path as an argument to the client, it will be uploaded:
+
+```bash
+# equivalent
 cat file | haste
 haste file
 ```
 
-## Changing the location of your haste server
+### Different Haste server
 
-By default, haste will point at `http://hastebin.com`.  You can change this by setting the value of `ENV['HASTE_SERVER']` to the URL of your haste server.  You can also use `alias` to make easy shortcuts if you commonly use a few hastes intermingled with each other.  To do that, you'd put something like this into ~.bash_profile:
+By default, `Haste` share page will point at `https://hastebin.com`. 
+If you have haste-server configured to serve bins on a separate domain, you also need to set ENV['HASTE_SHARE_SERVER'] value to that domain.
 
-``` bash
-alias work_haste="HASTE_SERVER=http://something.com haste"
+To set the value of share server, you can add the following to your ~.bash_profile:
+
+```bash
+export HASTE_SHARE_SERVER="myshareserver"
 ```
 
-After which you can use `work_haste` to send hastes to that server instead.
+### Different Haste server
 
-## Windows Support
+By default, haste server will point at `https://hastebin.com`. 
+You can change this by setting the value of `ENV['HASTE_SERVER']` to the URL of your `Haste` server.  
 
-If you'd like an alternative on Windows that supports functionality similar to `pbcopy`, check out Aidan Ryan's [WinHaste](https://github.com/ajryan/WinHaste) project.
+To set the value of server, you can add the following to your ~.bash_profile:
 
-## Author
+```bash
+export HASTE_SERVER="myserver"
+```
 
-John Crepezzi <john.crepezzi@gmail.com>
+### Use with alias
 
-## License
+You can also use `alias` to make easy shortcuts if you commonly use a few hastes intermingled with each other. 
+To do that, you'd put something like this into ~.bash_profile:
 
-(The MIT License)
+``` bash
+alias work_haste="HASTE_SERVER=https://something.com HASTE_SERVER_TOKEN=mytoken haste"
+```
 
-Copyright © 2011 John Crepezzi
+or
 
-Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the ‘Software’), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
+``` bash
+alias work_haste="HASTE_SERVER_TOKEN=mytoken haste"
+```
 
-The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
+After which you can use `work_haste` to send hastes to that server or with different tokens instead.
 
-THE SOFTWARE IS PROVIDED ‘AS IS’, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE
+
+### Use as a library
+
+You can also use `Haste` as a library to upload hastes:
+
+``` ruby
+require 'haste'
+uploader = Haste::Uploader.new
+uploader.upload_raw 'this is my data' # key
+uploader.upload_path '/tmp/whaaaa' # key
+```
+
+## Contributor License Agreement
+
+Licensed under the [MIT](https://github.com/toptal/haste-client/blob/master/LICENSE.txt 'https://github.com/toptal/haste-client/blob/main/LICENSE.txt') license.

Rakefile

@@ -1,7 +1,9 @@
 require 'rspec/core/rake_task'
 require File.dirname(__FILE__) + '/lib/haste/version'
- 
-task :build => :test do
+
+RSpec::Core::RakeTask.new(:spec)
+
+task :build => :spec do
   system "gem build haste.gemspec"
 end
 
@@ -12,14 +14,3 @@ task :release => :build do
   # push the gem
   system "gem push haste-#{Haste::VERSION}.gem"
 end
- 
-RSpec::Core::RakeTask.new(:test) do |t|
-  t.pattern = 'spec/**/*_spec.rb'
-  fail_on_error = true # be explicit
-end
- 
-RSpec::Core::RakeTask.new(:rcov) do |t|
-  t.pattern = 'spec/**/*_spec.rb'
-  t.rcov = true
-  fail_on_error = true # be explicit
-end

haste.gemspec

@@ -1,13 +1,16 @@
 require 'rubygems'
 require File.dirname(__FILE__) + '/lib/haste/version'
 
-spec = Gem::Specification.new do |s|
+Gem::Specification.new do |s|
   s.name = 'haste'
-  s.author = 'John Crepezzi'
+  s.author = 'Toptal'
   s.add_development_dependency('rspec')
   s.add_dependency('json')
+  s.add_dependency('faraday', '~> 0.9')
   s.description = 'CLI Haste Client'
-  s.email = 'john.crepezzi@gmail.com'
+  s.license = 'MIT License'
+  s.homepage = 'https://github.com/toptal/haste-client'
+  s.email = 'open-source@toptal.com'
   s.executables = 'haste'
   s.files = Dir['lib/**/*.rb', 'haste']
   s.platform = Gem::Platform::RUBY

lib/haste.rb

@@ -1,53 +1,6 @@
-require 'json'
-require 'net/http'
-require 'uri'
+require File.dirname(__FILE__) + '/haste/uploader'
+require File.dirname(__FILE__) + '/haste/exception'
+require File.dirname(__FILE__) + '/haste/cli'
 
 module Haste
-
-  DEFAULT_URL = 'http://hastebin.com'
-
-  class CLI
-
-    # Pull all of the data from STDIN
-    def initialize
-      if STDIN.tty?
-        abort 'No input file given' unless ARGV.length == 1
-        abort "#{file}: No such path" unless File.exists?(file = ARGV[0])
-        @input = open(file).read
-      else
-        @input = STDIN.readlines.join
-      end
-      # clean up
-      @input.strip!
-    end
-
-    # Upload the and output the URL we get back
-    def start
-      uri = URI.parse server
-      http = Net::HTTP.new uri.host, uri.port
-      response = http.post '/documents', @input
-      if response.is_a?(Net::HTTPOK)
-        data = JSON.parse(response.body)
-        method = STDOUT.tty? ? :puts : :print
-        STDOUT.send method, "#{server}/#{data['key']}"
-      else
-        abort "failure uploading: #{response.code}"
-      end
-    rescue JSON::ParserError => e
-      abort "failure uploading: #{response.code}"
-    rescue Errno::ECONNREFUSED => e
-      abort "failure connecting: #{e.message}"
-    end
-
-    private
-
-    def server
-      return @server if @server
-      @server = (ENV['HASTE_SERVER'] || Haste::DEFAULT_URL).dup
-      @server.chop! if server.end_with?('/')
-      @server
-    end
-
-  end
-
 end

lib/haste/cli.rb

@@ -0,0 +1,38 @@
+module Haste
+
+  class CLI
+
+    # Create a new uploader
+    def initialize
+      @uploader = Uploader.new(
+        ENV['HASTE_SERVER'],
+        ENV['HASTE_SERVER_TOKEN'],
+        ENV['HASTE_SHARE_SERVER'],
+        ENV['HASTE_USER'],
+        ENV['HASTE_PASS'],
+        ENV['HASTE_SSL_CERTS'])
+    end
+
+    # And then handle the basic usage
+    def start
+      # Take data in
+      if STDIN.tty?
+        key = @uploader.upload_path ARGV.first
+      else
+        key = @uploader.upload_raw STDIN.readlines.join
+      end
+      # Put together a URL
+      url = "#{@uploader.share_server_url}/share/#{key}"
+      # And write data out
+      if STDOUT.tty?
+        STDOUT.puts url
+      else
+        STDOUT.print url
+      end
+    rescue Exception => e
+      abort e.message
+    end
+
+  end
+
+end

lib/haste/exception.rb

@@ -0,0 +1,4 @@
+module Haste
+  class Exception < StandardError
+  end
+end

lib/haste/uploader.rb

@@ -0,0 +1,97 @@
+require 'json'
+require 'faraday'
+require 'uri'
+
+module Haste
+
+  DEFAULT_SERVER_URL = 'https://hastebin.com'
+  DEFAULT_SHARE_SERVER_URL = 'https://hastebin.com'
+
+  class Uploader
+
+    attr_reader :server_url, :server_token, :share_server_url, :server_user, :server_pass, :ssl_certs
+
+    def initialize(server_url = nil, server_token = nil, share_server_url = nil, server_user = nil, server_pass = nil, ssl_certs = nil)
+      @server_url = generate_url(server_url || Haste::DEFAULT_SERVER_URL)
+      @share_server_url = generate_url(share_server_url || Haste::DEFAULT_SHARE_SERVER_URL)
+      
+      @server_user = server_user
+      @server_token = server_token
+      @server_pass = server_pass
+      @ssl_certs   = ssl_certs
+    end
+
+    def generate_url(url)
+      url = url.dup
+      url = url.chop if url.end_with?('/')
+      return url
+    end
+
+    # Take in a path and return a key
+    def upload_path(path)
+      fail_with 'No input file given' unless path
+      fail_with "#{path}: No such path" unless File.exists?(path)
+      upload_raw open(path).read
+    end
+
+    # Take in data and return a key
+    def upload_raw(data)
+      data.rstrip!
+      response = do_post data
+      if response.status == 200
+        data = JSON.parse(response.body)
+        data['key']
+      else
+        fail_with "failure uploading: #{response.body}"
+      end
+    rescue JSON::ParserError => e
+      fail_with "failure parsing response: #{e.message}"
+    rescue Errno::ECONNREFUSED => e
+      fail_with "failure connecting: #{e.message}"
+    end
+
+    private
+
+    def post_path
+      parsed_uri = URI.parse(server_url)
+      "#{parsed_uri.path}/documents"
+    end
+
+    def do_post(data)
+      connection.post(post_path, data)
+    end
+
+    def connection
+      @connection ||= connection_set
+    end
+
+    def connection_set
+      return connection_https if @ssl_certs
+      connection_http
+    end
+
+    def connection_http
+      Faraday.new(:url => server_url) do |c|
+        connection_config(c)
+      end
+    end
+
+    def connection_https
+      Faraday.new(:url => server_url, :ssl => { :ca_path => @ssl_certs }) do |c|
+        connection_config(c)
+      end
+    end
+
+    def connection_config(config)
+      config.request :authorization, 'Bearer', @server_token if @server_token
+      config.basic_auth(@server_user, @server_pass) if @server_user
+      config.adapter Faraday.default_adapter
+    end
+
+    def fail_with(msg)
+      raise Exception.new(msg)
+    end
+
+  end
+
+end

lib/haste/version.rb

@@ -1,5 +1,3 @@
 module Haste
-
-  VERSION = '0.1.3'
-
+  VERSION = '0.3.0'
 end

spec/examples/uploader_spec.rb

@@ -0,0 +1,212 @@
+require 'spec_helper'
+
+describe Haste::Uploader do
+
+  let(:uploader) { Haste::Uploader.new(base) }
+
+  describe :upload_raw do
+
+    let(:data) { 'hello world' }
+    let(:base) { nil }
+    let(:error_message) do
+      begin
+        @key = uploader.upload_raw data
+        nil # nil otherwise
+      rescue Haste::Exception => e
+        e.message
+      end
+    end
+
+    context 'with a good response' do
+
+      let(:json) { '{"key":"hello"}' }
+
+      before do
+        ostruct = OpenStruct.new(:status => 200, :body => json)
+        expect(uploader.send(:connection)).to receive(:post).with('/documents', data).and_return(ostruct)
+      end
+
+      it 'should get the key' do
+        expect(error_message).to be_nil # no error
+        expect(@key).to eq('hello')
+      end
+
+    end
+
+    context 'with a bad json response' do
+
+      let(:json) { '{that:not_even_json}' }
+
+      before do
+        ostruct = OpenStruct.new(:status => 200, :body => json)
+        expect(uploader.send(:connection)).to receive(:post).with('/documents', data).and_return(ostruct)
+      end
+
+      it 'should get an error' do
+        expect(error_message).to start_with('failure parsing response: ')
+      end
+
+    end
+
+    context 'with a 404 response' do
+
+      before do
+        ostruct = OpenStruct.new(:status => 404, :body => 'ohno')
+        expect(uploader.send(:connection)).to receive(:post).with('/documents', data).and_return(ostruct)
+      end
+
+      it 'should get an error' do
+        expect(error_message).to eq('failure uploading: ohno')
+      end
+
+    end
+
+    context 'with a non-existent server' do
+
+      before do
+        error = Errno::ECONNREFUSED
+        expect(uploader.send(:connection)).to receive(:post).with('/documents', data).and_raise(error)
+      end
+
+      it 'should get the key' do
+        expect(error_message).to eq('failure connecting: Connection refused')
+      end
+
+    end
+
+  end
+
+  describe :upload_path do
+
+    let(:base) { nil }
+    let(:error_message) do
+      begin
+        uploader.upload_path path
+        nil # nil otherwise
+      rescue Haste::Exception => e
+        e.message
+      end
+    end
+
+    context 'with no path given' do
+
+      let(:path) { nil }
+
+      it 'should have an error' do
+        expect(error_message).to eq('No input file given')
+      end
+
+    end
+
+    context 'with an invalid path given' do
+
+      let(:path) { '/tmp/why-do-you-have-a-file-called-john' }
+
+      it 'should have an error' do
+        expect(error_message).to eq("#{path}: No such path")
+      end
+
+    end
+
+    context 'with a valid path' do
+
+      let(:data) { 'hello world' }
+      let(:path) { '/tmp/real' }
+      before { File.open(path, 'w') { |f| f.write(data) } }
+
+      before do
+        expect(uploader).to receive(:upload_raw).with(data) # check
+      end
+
+      it 'should not receive an error' do
+        expect(error_message).to be_nil
+      end
+
+    end
+
+  end
+
+  describe :post_path do
+
+    let(:post_path) { uploader.send(:post_path) }
+
+    context "when the server URL doesn't have a path" do
+
+      let(:base) { 'http://example.com/' }
+
+      it 'should return /documents' do
+        expect(post_path).to eq('/documents')
+      end
+
+    end
+
+    context "when the server URL has a path" do
+
+      let(:base) { 'http://example.com/friend' }
+
+      it 'should return /documents' do
+        expect(post_path).to eq('/friend/documents')
+      end
+
+    end
+
+    context "when the server URL has a path that ends with slash" do
+
+      let(:base) { 'http://example.com/friend/' }
+
+      it 'should return /documents appended to the path without a duplicate slash' do
+        expect(post_path).to eq('/friend/documents')
+      end
+
+    end
+
+  end
+
+  describe :server_url do
+
+    let(:server_url) { uploader.server_url }
+    let(:share_server_url) { uploader.share_server_url }
+
+    context 'with default constructor' do
+
+      let(:base) { nil }
+
+      it 'should use the default urls' do
+        expect(server_url).to eq(Haste::DEFAULT_SERVER_URL)
+        expect(share_server_url).to eq(Haste::DEFAULT_SHARE_SERVER_URL)
+      end
+
+    end
+
+    context 'with server url passed in constructor' do
+
+      context 'with a trailing slash' do
+
+        before { @string = 'hello/' }
+        let(:base) { @string }
+
+        it 'should remove the slash' do
+          expect(server_url).to eq(@string.chop)
+        end
+
+        it 'should not modify the original' do
+          expect(@string).to eq('hello/')
+        end
+
+      end
+
+      context 'with no trailing slash' do
+
+        let(:base) { 'hello' }
+
+        it 'should not chop the url' do
+          expect(server_url).to eq(base)
+        end
+
+      end
+
+    end
+
+  end
+
+end

spec/spec_helper.rb

@@ -0,0 +1,3 @@
+require 'ostruct'
+
+require File.dirname(__FILE__) + '/../lib/haste'