//private List<PostClass> _deletemessages = new List<PostClass>();
+ public TwitterApiAccessLevel AccessLevel
+ {
+ get
+ {
+ if (HttpTwitter.API11Enabled)
+ return MyCommon.TwitterApiInfo11.AccessLevel;
+ else
+ return MyCommon.TwitterApiInfo.AccessLevel;
+ }
+ }
+
+ protected void ResetApiStatus()
+ {
+ if (HttpTwitter.API11Enabled)
+ MyCommon.TwitterApiInfo11.Reset();
+ else
+ MyCommon.TwitterApiInfo.Reset();
+ }
+
public string Authenticate(string username, string password)
{
HttpStatusCode res;
var content = "";
- MyCommon.TwitterApiInfo.Reset();
+ this.ResetApiStatus();
try
{
res = twCon.AuthUserAndPass(username, password, ref content);
//OAuth PIN Flow
bool res;
- MyCommon.TwitterApiInfo.Reset();
+ this.ResetApiStatus();
try
{
res = twCon.AuthGetRequestToken(ref pinPageUrl);
HttpStatusCode res;
var content = "";
- MyCommon.TwitterApiInfo.Reset();
+ this.ResetApiStatus();
try
{
res = twCon.AuthGetAccessToken(pinCode);
public void ClearAuthInfo()
{
Twitter.AccountState = MyCommon.ACCOUNT_STATE.Invalid;
- MyCommon.TwitterApiInfo.Reset();
+ this.ResetApiStatus();
twCon.ClearAuthInfo();
}
{
Twitter.AccountState = MyCommon.ACCOUNT_STATE.Invalid;
}
- MyCommon.TwitterApiInfo.Reset();
+ this.ResetApiStatus();
twCon.Initialize(token, tokenSecret, username, userId);
_uname = username.ToLower();
if (AppendSettingDialog.Instance.UserstreamStartup) this.ReconnectUserStream();
if (MyCommon._endingFlag) return "";
if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return "";
- if (MyCommon.TwitterApiInfo.AccessLevel == TwitterApiAccessLevel.Read || MyCommon.TwitterApiInfo.AccessLevel == TwitterApiAccessLevel.ReadWrite)
+
+ if (this.AccessLevel == TwitterApiAccessLevel.Read || this.AccessLevel == TwitterApiAccessLevel.ReadWrite)
{
return "Auth Err:try to re-authorization.";
}
if (MyCommon._endingFlag) return "";
if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return "";
- if (MyCommon.TwitterApiInfo.AccessLevel == TwitterApiAccessLevel.Read || MyCommon.TwitterApiInfo.AccessLevel == TwitterApiAccessLevel.ReadWrite)
+
+ if (this.AccessLevel == TwitterApiAccessLevel.Read || this.AccessLevel == TwitterApiAccessLevel.ReadWrite)
{
return "Auth Err:try to re-authorization.";
}
return "";
}
+ // API v1.1
+ private string CreatePostsFromSearch11Json(string content, TabClass tab, bool read, int count, ref long minimumId, bool more)
+ {
+ TwitterDataModel.SearchResult11 items;
+ try
+ {
+ items = MyCommon.CreateDataFromJson<TwitterDataModel.SearchResult11>(content);
+ }
+ catch (SerializationException ex)
+ {
+ MyCommon.TraceOut(ex.Message + Environment.NewLine + content);
+ return "Json Parse Error(DataContractJsonSerializer)";
+ }
+ catch (Exception ex)
+ {
+ MyCommon.TraceOut(ex, MethodBase.GetCurrentMethod().Name + " " + content);
+ return "Invalid Json!";
+ }
+ foreach (var result in items.Statuses)
+ {
+ PostClass post = null;
+ post = CreatePostsFromStatusData(result);
+ if (post == null) continue;
+
+ if (minimumId > post.StatusId) minimumId = post.StatusId;
+ if (!more && post.StatusId > tab.SinceId) tab.SinceId = post.StatusId;
+ //二重取得回避
+ lock (LockObj)
+ {
+ if (tab == null)
+ {
+ if (TabInformations.GetInstance().ContainsKey(post.StatusId)) continue;
+ }
+ else
+ {
+ if (TabInformations.GetInstance().ContainsKey(post.StatusId, tab.TabName)) continue;
+ }
+ }
+
+ post.IsRead = read;
+ if ((post.IsMe && !read) && this._readOwnPost) post.IsRead = true;
+
+ if (tab != null) post.RelTabName = tab.TabName;
+ //非同期アイコン取得＆StatusDictionaryに追加
+ TabInformations.GetInstance().AddPost(post);
+ }
+
+ return "";
+ }
+
private string CreatePostsFromSearchJson(string content, TabClass tab, bool read, int count, ref long minimumId, bool more)
{
TwitterDataModel.SearchResult items;
if (!TabInformations.GetInstance().ContainsTab(tab)) return "";
- return this.CreatePostsFromSearchJson(content, tab, read, count, ref tab.OldestId, more);
+ if (HttpTwitter.API11Enabled)
+ return this.CreatePostsFromSearch11Json(content, tab, read, count, ref tab.OldestId, more);
+ else
+ return this.CreatePostsFromSearchJson(content, tab, read, count, ref tab.OldestId, more);
}
public string GetPhoenixSearch(bool read,
if (MyCommon._endingFlag) return "";
if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return "";
- if (MyCommon.TwitterApiInfo.AccessLevel == TwitterApiAccessLevel.Read || MyCommon.TwitterApiInfo.AccessLevel == TwitterApiAccessLevel.ReadWrite)
+
+ if (this.AccessLevel == TwitterApiAccessLevel.Read || this.AccessLevel == TwitterApiAccessLevel.ReadWrite)
{
return "Auth Err:try to re-authorization.";
}
public string GetListsApi()
{
+ return HttpTwitter.API11Enabled ? this.GetListsApi11() : this.GetListsApi10();
+ }
+
+ private string GetListsApi10()
+ {
if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return "";
HttpStatusCode res = HttpStatusCode.BadRequest;
return "";
}
+ private string GetListsApi11()
+ {
+ if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return "";
+
+ HttpStatusCode res = HttpStatusCode.BadRequest;
+ IEnumerable<ListElement> lists;
+ var content = "";
+
+ try
+ {
+ res = twCon.GetLists(this.Username, null, ref content);
+ }
+ catch (Exception ex)
+ {
+ return "Err:" + ex.Message + "(" + MethodBase.GetCurrentMethod().Name + ")";
+ }
+
+ switch (res)
+ {
+ case HttpStatusCode.OK:
+ Twitter.AccountState = MyCommon.ACCOUNT_STATE.Valid;
+ break;
+ case HttpStatusCode.Unauthorized:
+ Twitter.AccountState = MyCommon.ACCOUNT_STATE.Invalid;
+ return Properties.Resources.Unauthorized;
+ case HttpStatusCode.BadRequest:
+ return "Err:API Limits?";
+ default:
+ return "Err:" + res.ToString() + "(" + MethodBase.GetCurrentMethod().Name + ")";
+ }
+
+ try
+ {
+ lists = MyCommon.CreateDataFromJson<List<TwitterDataModel.ListElementData>>(content)
+ .Select(x => new ListElement(x, this));
+ }
+ catch (SerializationException ex)
+ {
+ MyCommon.TraceOut(ex.Message + Environment.NewLine + content);
+ return "Err:Json Parse Error(DataContractJsonSerializer)";
+ }
+ catch (Exception ex)
+ {
+ MyCommon.TraceOut(ex, MethodBase.GetCurrentMethod().Name + " " + content);
+ return "Err:Invalid Json!";
+ }
+
+ content = "";
+ try
+ {
+ res = twCon.GetListsSubscriptions(this.Username, null, ref content);
+ }
+ catch (Exception ex)
+ {
+ return "Err:" + ex.Message + "(" + MethodBase.GetCurrentMethod().Name + ")";
+ }
+
+ switch (res)
+ {
+ case HttpStatusCode.OK:
+ Twitter.AccountState = MyCommon.ACCOUNT_STATE.Valid;
+ break;
+ case HttpStatusCode.Unauthorized:
+ Twitter.AccountState = MyCommon.ACCOUNT_STATE.Invalid;
+ return Properties.Resources.Unauthorized;
+ case HttpStatusCode.BadRequest:
+ return "Err:API Limits?";
+ default:
+ return "Err:" + res.ToString() + "(" + MethodBase.GetCurrentMethod().Name + ")";
+ }
+
+ try
+ {
+ lists = lists.Concat(MyCommon.CreateDataFromJson<List<TwitterDataModel.ListElementData>>(content)
+ .Select(x => new ListElement(x, this)));
+ }
+ catch (SerializationException ex)
+ {
+ MyCommon.TraceOut(ex.Message + Environment.NewLine + content);
+ return "Err:Json Parse Error(DataContractJsonSerializer)";
+ }
+ catch (Exception ex)
+ {
+ MyCommon.TraceOut(ex, MethodBase.GetCurrentMethod().Name + " " + content);
+ return "Err:Invalid Json!";
+ }
+
+ TabInformations.GetInstance().SubscribableLists = lists.ToList();
+ return "";
+ }
+
public string DeleteList(string list_id)
{
HttpStatusCode res = HttpStatusCode.BadRequest;
}
}
- public bool GetInfoApi()
+ public TwitterApiStatus GetInfoApi10()
{
- if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return true;
+ if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return null;
- if (MyCommon._endingFlag) return true;
+ if (MyCommon._endingFlag) return null;
HttpStatusCode res = HttpStatusCode.BadRequest;
var content = "";
}
catch(Exception)
{
- MyCommon.TwitterApiInfo.Reset();
- return false;
+ this.ResetApiStatus();
+ return null;
}
- if (res != HttpStatusCode.OK) return false;
+ if (res != HttpStatusCode.OK) return null;
try
{
var limit = MyCommon.CreateDataFromJson<TwitterDataModel.RateLimitStatus>(content);
MyCommon.TwitterApiInfo.UpdateFromApi(limit);
- return true;
+
+ return MyCommon.TwitterApiInfo;
}
catch(Exception ex)
{
MyCommon.TraceOut(ex, MethodBase.GetCurrentMethod().Name + " " + content);
MyCommon.TwitterApiInfo.Reset();
- return false;
+ return null;
}
}
+
+ public TwitterApiStatus11 GetInfoApi11()
+ {
+ if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return null;
+
+ if (MyCommon._endingFlag) return null;
+
+ HttpStatusCode res = HttpStatusCode.BadRequest;
+ var content = "";
+ try
+ {
+ res = twCon.RateLimitStatus(ref content);
+ }
+ catch (Exception)
+ {
+ this.ResetApiStatus();
+ return null;
+ }
+
+ if (res != HttpStatusCode.OK) return null;
+
+ try
+ {
+ MyCommon.TwitterApiInfo11.UpdateFromJson(content);
+ return MyCommon.TwitterApiInfo11;
+ }
+ catch (Exception ex)
+ {
+ MyCommon.TraceOut(ex, MethodBase.GetCurrentMethod().Name + " " + content);
+ MyCommon.TwitterApiInfo.Reset();
+ return null;
+ }
+ }
+
public string GetBlockUserIds()
{
if (Twitter.AccountState != MyCommon.ACCOUNT_STATE.Valid) return "";
OSDN Git Service
