def test_location_support(self):
     client = stream.connect('a', 'b', 'c', location='us-east')
     full_location = 'https://us-east-api.getstream.io/api/'
     self.assertEqual(client.location, 'us-east')
     self.assertEqual(client.base_url, full_location)
     # test a wrong location
     client = stream.connect('a', 'b', 'c', location='nonexistant')
     def get_feed():
         client.feed('user', '1').get()
     self.assertRaises(ConnectionError, get_feed)

 def test_heroku_real(self):
     url = 'https://bvt88g4kvc63:t[email protected]getstream.io/?site=669'
     os.environ['STREAM_URL'] = url
     client = stream.connect()
     self.assertEqual(client.api_key, 'bvt88g4kvc63')
     self.assertEqual(client.api_secret, 'twc5ywfste5bm2ngqkzs7ukxk3pn96yweghjrxcmcrarnt3j4dqj3tucbhym5wfd')
     self.assertEqual(client.site_id, '669')

def connect_debug():
    return stream.connect(
        'gav9ygr75by3',
        '5ws2hnua79n9qga6e2dy572qdfapwgdc83853mjm3mjp66czyb2xkahbdhs98an8',
        location='us-east',
        timeout=10
    )

def value_storage(request):
	resp = {"success":False, "msgs":['Cannot store the current operation.']}
	
	if request.method == 'POST':
		user_name = request.POST['name']
		memory_value = request.POST['memory_value']
		results_value = request.POST['results_value']
		a = Calculations(name=user_name,operations=memory_value,result=results_value)
		a.save()
		client = stream.connect('tzn84uddddhm', 'hd722ggruc6s6qjzrdskywtctug63r2h396yjhamrbe72cztqgnmkzzvzmh3dzv9', location='eu-central')
		

		# Create a bit more complex activity
		user_feed_1 = client.feed('user', '1')
		activity_data = {'actor': '1', 'verb': 'run', 'object': 'test',
		    'participants': ['Sibi'],
		    'started_at': datetime.datetime.now(),
		    'foreign_id': 'run:1'
		}
		user_feed_1.add_activity(activity_data)
		notification_feed = client.feed('user', '1')

		print memory_value
		print results_value
		print user_name
		resp = {"success":True, "msgs":['Operation has been updated']}
	return HttpResponse(json.dumps(resp))

 def test_heroku(self):
     url = 'https://thierry:[email protected]/?app_id=1'
     os.environ['STREAM_URL'] = url
     client = stream.connect()
     self.assertEqual(client.api_key, 'thierry')
     self.assertEqual(client.api_secret, 'pass')
     self.assertEqual(client.app_id, '1')

 def test_heroku_overwrite(self):
     url = 'https://thierry:[email protected]/?app_id=1'
     os.environ['STREAM_URL'] = url
     client = stream.connect('a', 'b', 'c')
     self.assertEqual(client.api_key, 'a')
     self.assertEqual(client.api_secret, 'b')
     self.assertEqual(client.app_id, 'c')

def test_original_server():
    client = stream.connect('5e62adrfbcxw', 'qxshw6rvbgcv4ghb342fevzp75h53qhga8vajmd6s4pr6f7kcyfx72w5j693xe3t')
    f = client.feed('feed', "user_9_0_5600c2359e08b6b9653ce87e_official")
    res = f.get(offset=0,limit=1)
    print res

    assert 'duration' in res
    assert 'results' in res
    assert 'next' in res
    assert len(res['results']) <= 1

 def test_heroku_location(self):
     url = 'https://ahj2ndz7gsan:g[email protected]us-east.getstream.io/?app_id=1'
     os.environ['STREAM_URL'] = url
     client = stream.connect()
     self.assertEqual(client.api_key, 'ahj2ndz7gsan')
     self.assertEqual(
         client.api_secret, 'gthc2t9gh7pzq52f6cky8w4r4up9dr6rju9w3fjgmkv6cdvvav2ufe5fv7e2r9qy')
     self.assertEqual(
         client.base_url, 'https://us-east-api.getstream.io/api/')
     self.assertEqual(client.app_id, '1')

 def test_api_key_exception(self):
     self.c = stream.connect(
         '5crf3bhfzesnMISSING',
         'tfq2sdqpj9g446sbv653x3aqmgn33hsn8uzdc9jpskaw8mj6vsnhzswuwptuj9su'
     )
     self.user1 = self.c.feed('user', '1')
     activity_data = {'actor': 1, 'verb': 'tweet',
                      'object': 1, 'debug_example_undefined': 'test'}
     self.assertRaises(ApiKeyException, lambda:
                       self.user1.add_activity(activity_data))

def test_new_server():
    client = stream.connect('5e62adrfbcxw', 'qxshw6rvbgcv4ghb342fevzp75h53qhga8vajmd6s4pr6f7kcyfx72w5j693xe3t')
    # change from original endpoint to the new one to test
    client.base_url = "http://192.168.99.100:5000/api/"
    f = client.feed('feed', "user_9_0_5600c2359e08b6b9653ce87e_official")
    res = f.get(offset=0,limit=1)
    print res

    assert 'duration' in res
    assert 'results' in res
    assert 'next' in res
    assert len(res['results']) <= 1

def home(request):
	a = 'sibi test getStream'
	client = stream.connect('tzn84uddddhm', 'hd722ggruc6s6qjzrdskywtctug63r2h396yjhamrbe72cztqgnmkzzvzmh3dzv9', location='eu-central')
	

	# Create a bit more complex activity
	user_feed_1 = client.feed('user', '1')
	activity_data = {'actor': '1', 'verb': 'run', 'object': 'test',
	    'participants': ['Sibi'],
	    'started_at': datetime.datetime.now(),
	    'foreign_id': 'run:1'
	}
	user_feed_1.add_activity(activity_data)
	notification_feed = client.feed('user', '1')

	return render(request, 'home.html',
                {
                'a':a,
                'token':notification_feed.token,
                })

 def test_wrong_feed_spec(self):
     self.c = stream.connect(
         '5crf3bhfzesnMISSING',
         'tfq2sdqpj9g446sbv653x3aqmgn33hsn8uzdc9jpskaw8mj6vsnhzswuwptuj9su'
     )
     self.assertRaises(TypeError, lambda: getfeed('user1'))

from stream_django import conf
import os
import stream
from django.core.exceptions import ImproperlyConfigured

if conf.API_KEY and conf.API_SECRET:
    stream_client = stream.connect(
        conf.API_KEY, conf.API_SECRET, location=conf.LOCATION, timeout=conf.TIMEOUT)
else:
    stream_client = stream.connect()

if os.environ.get('STREAM_URL') is None and not(conf.API_KEY and conf.API_SECRET):
    raise ImproperlyConfigured('Stream credentials are not set in your settings')

import stream
import os
from app import app

client = stream.connect(app.config['API_KEY'], app.config['API_SECRET'])

from stream_django import conf
import os
import stream
from django.core.exceptions import ImproperlyConfigured

if conf.API_KEY and conf.API_SECRET:
    stream_client = stream.connect(
        conf.API_KEY, conf.API_SECRET, location=conf.LOCATION)
else:
    stream_client = stream.connect()

if os.environ.get('STREAM_URL') is None and not(conf.API_KEY and conf.API_SECRET):
    raise ImproperlyConfigured('Stream credentials are not set in your settings')

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author: Administrator
# @Date:   2015-08-10 10:04:04
# @Last Modified by:   Administrator
# @Last Modified time: 2015-08-10 10:04:09

import stream
client = stream.connect('wuu4zhjnj2k2', '8u8npqaamm8qr8pysumfrp9s5umc77yvvqyhkqsukm6drpmhm5xw5pbxbxwr9tbp')
# Get the feed object
eric_feed = client.feed('user', 'eric')
# Add the activity to the feed
eric_feed.add_activity({'actor': 'eric', 'verb': 'tweet', 'object': 1, 'tweet': 'Hello world'});

import stream

# SCALABLE NEWS FEED
#Works for 3 users but can be changed for more

#Part 1
client = stream.connect('8d2pm9kfhbt4', 'bpqn7haggg75qdjuwgfagfu4n9wspekn2hq8z88wq2hm7j3btym45p7g3rrmg6gt')
# Get the feed object
eric_feed = client.feed('user', 'eric')
# Add the activity to the feed
eric_feed.add_activity({'actor': 'eric', 'verb': 'tweet', 'object': 1, 'tweet': 'Hello world'});

#Part 2
# Let Jessica's flat feed follow Eric's and Rick's feeds
jessica_flat_feed = client.feed('flat', 'jessica')
jessica_flat_feed.follow('user', 'eric')
jessica_flat_feed.follow('user', 'rick')

# activities on Eric's personal feed will flow automatically in Jessica's feed
user1 = client.feed('user', '1')
user1.add_activity({'actor': 1, 'verb': 'watch', 'object': 1, 'youtube_id': 'z_AbfPXTKms'});

# Read the activities from Jessica's flat feed
response = jessica_flat_feed.get(limit=3)

def connect_debug():
    return stream.connect(
        u'ahj2ndz7gsan',
        u'gthc2t9gh7pzq52f6cky8w4r4up9dr6rju9w3fjgmkv6cdvvav2ufe5fv7e2r9qy'
    )

from Models import JoinClubMiniForm
from Models import FollowClubMiniForm
from Models import ClubListResponse
from Models import ProfileMiniForm,Events,Event,ModifyEvent
from Models import ClubRetrievalMiniForm
from Models import RequestMiniForm
from CollegesAPI import getColleges,createCollege
from PostsAPI import postEntry,postRequest,deletePost,unlikePost,likePost,commentForm,copyPostToForm,editpost
from PostsAPI import copyPostRequestToForm,update
from EventsAPI import eventEntry,copyEventToForm,deleteEvent,attendEvent
from ClubAPI import createClub,createClubAfterApproval,getClub,unfollowClub
from ProfileAPI import _copyProfileToForm,_doProfile,_getProfileFromUser
from settings import ANROID_CLIENT_ID,WEB_CLIENT_ID
EMAIL_SCOPE = endpoints.EMAIL_SCOPE
API_EXPLORER_CLIENT_ID = endpoints.API_EXPLORER_CLIENT_ID
client = stream.connect('pp5fhr4zu9zt', '3ndmbn5879tw5bdwur43583z4qc9327r4nkn8r7frtj6s6djf5hxw94e46wuccsx')
@endpoints.api(name='clubs', version='v1',
    allowed_client_ids=[ANROID_CLIENT_ID,WEB_CLIENT_ID,API_EXPLORER_CLIENT_ID],
    scopes=[EMAIL_SCOPE])

# GETSTREAM KEY - urgm3xjebe9d

class ClubApi(remote.Service):

   @endpoints.method(GetClubMiniForm,ClubMiniForm,path='getClub', http_method='POST', name='getClub')
   def getClubApi(self,request):
        print("Request entity is",request)
        retClub = ClubMiniForm()
        if request:
             retClub = getClub(request)

def calculator(request):
	value = Calculations.objects.all().order_by('-time')
	client = stream.connect('tzn84uddddhm', 'hd722ggruc6s6qjzrdskywtctug63r2h396yjhamrbe72cztqgnmkzzvzmh3dzv9', location='eu-central')
	notification_feed = client.feed('user', '1')
	return render(request, 'calculator.html',{'value':value,'token':notification_feed.token})