Packages

blazay

1.2.0
1.2.0 1.1.6 1.1.5 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.9 1.0.8 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.2.0 0.1.0

Compressor is a distributed video compressor. It's designed to be used with Upmaru Studio

HexDocs

Current section

Files

Jump to
Readme
20 Versions
4 Dependencies
Dependants
Files
Activity
blazay lib blazay worker chunk.ex
Raw

lib/blazay/worker/chunk.ex 

defmodule Blazay.Worker.Chunk do

  @moduledoc """

  Handles uploading of chunks (pieces from the client)

  """

  use Blazay.Worker.Base



  def task(state) do

    {:ok, checksum} = Checksum.start_link

    {:ok, part_url} = Upload.part_url(state.uid.file_id)



    index = state.uid.index



    header = %{

      authorization: part_url.authorization_token,

      x_bz_part_number: (index + 1),

      content_length: state.job.content_length + 40,

      x_bz_content_sha1: "hex_digits_at_end"

    }



    body = Flow.generate(state.job.stream, index, checksum)



    try do

      Upload.part(part_url.upload_url, header, body)

    after

      Checksum.stop(checksum)

    end

  end

end