Oauth streaming doesn't work

oshadhaviraj · 2013-09-19T09:27:08.000Z

Hi all,

I’m kind of new to Twitter streaming API. And I’m trying to get this beautiful and minimalist Scala wrapper for streaming API to get work.

GitHub

acrosa/Scala-TwitterStreamer

Scala-TwitterStreamer - Scala client for the Twitter streaming api

But unfortunately I end up getting this weird error

HttpMethodDirector - Failure authenticating with BASIC 'Firehose'@stream.twitter.com:443
org.apache.commons.httpclient.HttpException: There was a problem connecting, HTTP code received was: 401 HTTP/1.1 401 Unauthorized

I checked the Authorization header and it all looks OK to me.

oauth_signature_method -> HMAC-SHA1, 
oauth_signature -> YVbrIgokxdhbZ1AixdlLGaLWrfw=, 
oauth_consumer_key -> ********************************, 
oauth_version -> 1.0, 
oauth_token -> ********************************************************, 
oauth_timestamp -> 1379582015, 
oauth_nonce -> wKqKGNNCtU2ND1j5xYR0oiTraBrF7i6m

The signature generation mechanism is also looks good to me as compared to https://dev.twitter.com/docs/auth/creating-signature

You can further look to the .scala where the place it get generated

github.com

acrosa/Scala-TwitterStreamer/blob/master/src/main/scala/com/streamer/twitter/oauth/OAuth.scala

package com.streamer.twitter.oauth

import collection.Map
import collection.immutable.{ TreeMap, Map => IMap }

import javax.crypto
import java.net.URI

import org.apache.commons.codec.binary.Base64.encodeBase64
import org.apache.commons.httpclient.HttpMethod

case class Consumer(key: String, secret: String)
case class Token(value: String, secret: String)

object OAuth {
  private val UTF_8 = "UTF-8"
  private val charset = UTF_8
  private val SHA1 = "HmacSHA1"

  private def encode (string: String): String = java.net.URLEncoder.encode(string, charset)

This file has been truncated. show original

Starting from line 52

Can someone point me out where the issue is?