「Unity/Firebase/CloudFunctions」の版間の差分
提供: 初心者エンジニアの簡易メモ
(→サンプル) |
|||
| 行90: | 行90: | ||
// onComplete | // onComplete | ||
string json = task.Result.ToString(); | string json = task.Result.ToString(); | ||
| − | Debug.Log("json=" + json); | + | Debug.Log("json=" + json); // {"status":"ok","notice":"","users":[{"point":140,"name":"siro"},{"point":130,"name":"saburo"},{"point":120,"name":"jiro"}]} |
ResData resData = JsonUtility.FromJson<ResData>(json); | ResData resData = JsonUtility.FromJson<ResData>(json); | ||
Debug.Log("status=" + resData.status); | Debug.Log("status=" + resData.status); | ||
2019年8月7日 (水) 01:50時点における版
準備
Gcp/Firebase/CloudFunctions [ショートカット]
import
FirebaseFunctions.unitypackage をunityのAssets/ImportPackage/CustomPackageからImportする
初期化
using Firebase.Functions; FirebaseFunctions functions = FirebaseFunctions.DefaultInstance;
東京リージョンの場合こちらを記述
using Firebase.Functions;
FirebaseFunctions functions = FirebaseFunctions.GetInstance("asia-northeast1");
サンプル
ScoreEntry score = new ScoreEntry(); AddEntry(score); GetTopEntries();
using System.Threading.Tasks;
class ScoreEntry {
public string Name = "taro";
public int Point = 100;
}
async Task<object> AddEntryAsync(ScoreEntry score)
{
object data = new Dictionary<object, object>
{
{ "name", score.Name },
{ "point", score.Point },
};
return await functions.GetHttpsCallable("addEntry").CallAsync(data)
.ContinueWith(task =>
{
return task.Result.Data;
});
}
void AddEntry(ScoreEntry score)
{
AddEntryAsync(score).ContinueWith(task =>
{
if (task.IsFaulted)
{
// onError
}
else
{
// onComplete
Debug.Log("task.Result=" + task.Result); // OK
}
}, TaskScheduler.FromCurrentSynchronizationContext());
}
[Serializable]
class ResData
{
public string status = "ok";
public string notice = "";
public List<ResUser> users;
}
[Serializable]
class ResUser
{
public int point = 0;
public string name = "";
}
async Task<object> GetTopEntriesAsync()
{
object data = new Dictionary<object, object>
{
{ "count", 3 },
};
return await functions.GetHttpsCallable("getTopEntries").CallAsync(data)
.ContinueWith(task =>
{
return task.Result.Data;
});
}
void GetTopEntries()
{
GetTopEntriesAsync().ContinueWith(task =>
{
if (task.IsFaulted)
{
// onError
}
else
{
// onComplete
string json = task.Result.ToString();
Debug.Log("json=" + json); // {"status":"ok","notice":"","users":[{"point":140,"name":"siro"},{"point":130,"name":"saburo"},{"point":120,"name":"jiro"}]}
ResData resData = JsonUtility.FromJson<ResData>(json);
Debug.Log("status=" + resData.status);
Debug.Log("notice=" + resData.notice);
foreach (ResUser user in resData.users)
{
Debug.Log("user.name=" + user.name);
Debug.Log("user.point=" + user.point);
}
}
}, TaskScheduler.FromCurrentSynchronizationContext());
}
firebaseのサーバー側変更
functions.https.onCall を使ってシリアル&認証トークンで接続するようにする
const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();
// 追加
exports.addEntry = functions
.region('asia-northeast1')
.https.onCall((data, context) =>
{
const entry = {
name : data.name,
point : data.point
};
return admin.firestore().collection('entries')
.add(entry)
.then((snapshot) =>
{
return 'OK';
});
});
// 更新
exports.replaceEntry = functions
.region('asia-northeast1')
.https.onCall((data, context) =>
{
const entry = {
name : data.name,
point : data.point
};
return admin.firestore().collection('entries')
.doc("ID1").set(entry)
.then((snapshot) =>
{
return 'OK';
});
});
// トップcount件のEntryを取得
exports.getTopEntries = functions
.region('asia-northeast1')
.https.onCall((data, context) =>
{
const count = data.count;
return admin.firestore().collection('entries')
.orderBy('point', 'desc')
.limit(count)
.get()
.then((snapshot) =>
{
var obj = {
status: 'ok',
notice: '',
users: snapshot.docs.map(x => x.data()),
}
var json=JSON.stringify(obj);
return json;
});
});
参考
https://firebase.google.com/docs/functions/callable?hl=ja
https://devlog.hassaku.blue/2019/03/unity-firebase-firebase.html
https://firebase.google.com/docs/reference/unity/class/firebase/functions/firebase-functions
