Store data in database (TypeORM)

babel.config.js

@@ -1,6 +1,9 @@
-module.exports = function(api) {
+module.exports = function (api) {
   api.cache(true);
   return {
-    presets: ['babel-preset-expo'],
+    presets: ["babel-preset-expo"],
+    plugins: [
+      "babel-plugin-transform-typescript-metadata", // https://github.com/typeorm/expo-example/blob/master/babel.config.js
+    ],
   };
 };

config/survey.json

@@ -11,16 +11,16 @@
       "randomMinuteAddition": { "min": 0, "max": 119 }
     },
     "streamsOrder": {
-      "0": ["streamName", "streamName", "streamName", "streamName"],
-      "1": ["streamName", "streamName", "streamName", "streamName"],
-      "2": ["streamName", "streamName", "streamName", "streamName"],
-      "3": ["streamName", "streamName", "streamName", "streamName"],
-      "4": ["streamName", "streamName", "streamName", "streamName"],
-      "5": ["streamName", "streamName", "streamName", "streamName"],
-      "6": ["streamName", "streamName", "streamName", "streamName"]
+      "0": ["myStream", "myStream", "myStream", "myStream"],
+      "1": ["myStream", "myStream", "myStream", "myStream"],
+      "2": ["myStream", "myStream", "myStream", "myStream"],
+      "3": ["myStream", "myStream", "myStream", "myStream"],
+      "4": ["myStream", "myStream", "myStream", "myStream"],
+      "5": ["myStream", "myStream", "myStream", "myStream"],
+      "6": ["myStream", "myStream", "myStream", "myStream"]
     },
-    "streamInCaseOfError": "streamName",
-    "streamsNotReplacedByFollowupStream": ["streamName"],
+    "streamInCaseOfError": "errorStream",
+    "streamsNotReplacedByFollowupStream": ["myStream"],
     "notificationContent": {
       "default": {
         "title": "You have a new survey!",
@@ -36,11 +36,12 @@
   },
   "meta": {
     "startingQuestionIds": {
-      "streamName": "Feel_Current"
+      "myStream": "Feel_Current",
+      "errorStream": "firstQuestion"
     }
   },
   "streams": {
-    "streamName": {
+    "myStream": {
       "Feel_Current": {
         "id": "Feel_Current",
         "type": "slider",
@@ -137,6 +138,15 @@
         "indexName": "INDEX",
         "next": null
       }
+    },
+    "errorStream": {
+      "firstQuestion": {
+        "id": "firstQuestion",
+        "type": "slider",
+        "question": "Why are we here?",
+        "slider": ["extremely negative", "extremely positive"],
+        "next": null
+      }
     }
   }
 }

package.json

@@ -12,17 +12,25 @@
     "expo-constants": "~9.0.0",
     "expo-crypto": "~8.1.0",
     "expo-device": "~2.1.0",
+    "expo-file-system": "~8.1.0",
+    "expo-sqlite": "~8.1.0",
     "expo-web-browser": "~8.2.1",
     "lodash": "^4.17.15",
     "react": "16.9.0",
     "react-native": "https://github.com/expo/react-native/archive/sdk-37.0.1.tar.gz",
-    "react-native-webview": "8.1.1"
+    "react-native-sqlite-storage": "^5.0.0",
+    "react-native-webview": "8.1.1",
+    "reflect-metadata": "^0.1.13",
+    "typeorm": "^0.2.25",
+    "url": "^0.11.0"
   },
   "devDependencies": {
+    "@types/node": "^14.0.13",
     "@types/react": "^16.9.11",
     "@types/react-native": "^0.60.22",
     "@typescript-eslint/eslint-plugin": "^3.2.0",
     "@typescript-eslint/parser": "^3.2.0",
+    "babel-plugin-transform-typescript-metadata": "^0.3.0",
     "babel-preset-expo": "^8.1.0",
     "eslint": "^7.2.0",
     "eslint-config-prettier": "^6.11.0",

src/HomeScreen.tsx

@@ -16,6 +16,8 @@ import {
 import { WebView } from "react-native-webview";
 
 import SurveyScreen, { SurveyScreenState } from "./SurveyScreen";
+import { AnswerEntity } from "./entities/AnswerEntity";
+import { PingEntity } from "./entities/PingEntity";
 import {
   uploadDataAsync,
   getAllDataAsync,
@@ -25,22 +27,23 @@ import {
 import {
   getNotificationTimesAsync,
   clearNotificationTimesAsync,
-  getPingsAsync,
-  initPingAsync,
   insertPingAsync,
-  clearPingsAsync,
-  getLatestStartedPingAsync,
+  getLatestPingAsync,
   getPingStateAsync,
-  PingInfo,
   getTodayPingsAsync,
   dequeueFuturePingIfAny,
   initFuturePingQueueAsync,
   getFuturePingsQueue,
   clearPingStateAsync,
-  getTypesOfPingsAnsweredAsync,
+  getNumbersOfPingsForAllStreamNames,
 } from "./helpers/asyncStorage";
 import { getAllStreamNames } from "./helpers/configFiles";
+import {
+  shareDatabaseFileAsync,
+  deleteDatabaseFileAsync,
+} from "./helpers/database";
 import { getNonCriticalProblemTextForUser } from "./helpers/debug";
+import { QuestionType } from "./helpers/helpers";
 import {
   setNotificationsAsync,
   setupNotificationsPermissionAsync,
@@ -77,7 +80,7 @@ interface HomeScreenState {
   time: Date;
   allowsNotifications: boolean;
   currentNotificationTime: Date | null;
-  currentPing: PingInfo | null;
+  currentPing: PingEntity | null;
   isLoading: boolean;
   storedPingStateAsync: SurveyScreenState | null;
 
@@ -160,22 +163,20 @@ export default class HomeScreen extends React.Component<
       await doEveryHalfMinutes();
     });
 
-    const latestStartedPing = await getLatestStartedPingAsync();
+    const latestPing = await getLatestPingAsync();
     //console.warn(latestStartedPing);
     const currentNotificationTime = await getCurrentNotificationTimeAsync();
     if (
-      latestStartedPing &&
+      latestPing &&
       currentNotificationTime &&
-      latestStartedPing.notificationTime.getTime() ===
+      latestPing.notificationTime.getTime() ===
         currentNotificationTime.getTime()
     ) {
-      const storedPingStateAsync = await getPingStateAsync(
-        latestStartedPing.id,
-      );
+      const storedPingStateAsync = await getPingStateAsync(latestPing.id);
       //console.warn(storedPingStateAsync);
       this.setState({
         storedPingStateAsync,
-        currentPing: latestStartedPing,
+        currentPing: latestPing,
       });
     }
 
@@ -193,7 +194,7 @@ export default class HomeScreen extends React.Component<
     const todayPings = await getTodayPingsAsync();
     let newPingName: StreamName;
 
-    if (todayPings.length > studyInfo.frequency.hoursEveryday.length) {
+    if (todayPings.length >= studyInfo.frequency.hoursEveryday.length) {
       alert(
         getNonCriticalProblemTextForUser(
           `todayPings.length (${todayPings.length}) > ${studyInfo.frequency.hoursEveryday.length}`,
@@ -347,6 +348,33 @@ export default class HomeScreen extends React.Component<
               this.setState({ displayDebugView: false });
             }}
           />
+          <Button
+            color="orange"
+            title="shareDatabaseFileAsync"
+            onPress={async () => {
+              /*const ping = new PingEntity();
+              ping.id = "another";
+              ping.notificationTime = new Date();
+              ping.startTime = new Date();
+              ping.streamName = "one";
+              ping.tzOffset = 700;
+              await ping.save();
+
+              const answer = new AnswerEntity();
+              answer.ping = ping;
+              answer.questionId = "qu";
+              answer.questionType = QuestionType.YesNo;
+              answer.preferNotToAnswer = false;
+              answer.nextWithoutOption = false;
+              answer.data = {
+                value: "haha",
+              };
+              answer.lastUpdateDate = new Date();
+              await answer.save();*/
+
+              await shareDatabaseFileAsync(survey.studyInfo.id);
+            }}
+          />
           <Button
             color="orange"
             title="getIncomingNotificationTimeAsync()"
@@ -361,9 +389,9 @@ export default class HomeScreen extends React.Component<
           />
           <Button
             color="orange"
-            title="getLatestStartedPingAsync()"
+            title="getLatestPingAsync()"
             onPress={async () => {
-              const latestStartedPing = await getLatestStartedPingAsync();
+              const latestStartedPing = await getLatestPingAsync();
               alert(JSON.stringify(latestStartedPing));
             }}
           />
@@ -379,7 +407,7 @@ export default class HomeScreen extends React.Component<
             color="red"
             title="clear current ping state"
             onPress={async () => {
-              const latestStartedPing = await getLatestStartedPingAsync();
+              const latestStartedPing = await getLatestPingAsync();
               if (latestStartedPing) {
                 await clearPingStateAsync(latestStartedPing.id);
                 alert("Cleared. Please restart app");
@@ -402,9 +430,9 @@ export default class HomeScreen extends React.Component<
           />
           <Button
             color="orange"
-            title="getTypesOfPingsAnsweredAsync()"
+            title="getNumbersOfPingsForAllStreamNames()"
             onPress={async () => {
-              const typesOfPingsAnswered = await getTypesOfPingsAnsweredAsync();
+              const typesOfPingsAnswered = await getNumbersOfPingsForAllStreamNames();
               alert(JSON.stringify(typesOfPingsAnswered));
             }}
           />
@@ -528,8 +556,8 @@ export default class HomeScreen extends React.Component<
                     text: "Confirm",
                     style: "destructive",
                     onPress: async () => {
-                      await clearPingsAsync();
-                      await initPingAsync();
+                      await deleteDatabaseFileAsync(survey.studyInfo.id);
+                      alert("Done! Please restart the app.");
                     },
                   },
                 ],
@@ -613,7 +641,7 @@ export default class HomeScreen extends React.Component<
           surveyStartingQuestionId={
             survey.meta.startingQuestionIds[currentPing.streamName]
           }
-          pingId={currentPing.id}
+          ping={currentPing}
           previousState={this.state.storedPingStateAsync}
           onFinish={async (finishedPing) => {
             this.setState({ currentPing: finishedPing });

src/RootScreen.tsx

@@ -5,6 +5,7 @@ import { Button, TextInput, Text, View, ScrollView, Alert } from "react-native";
 import HomeScreen from "./HomeScreen";
 import { registerUserAsync } from "./helpers/apiManager";
 import { getSurveyFileAsync } from "./helpers/configFiles";
+import { connectDatabaseAsync } from "./helpers/database";
 import { getCriticalProblemTextForUser } from "./helpers/debug";
 import { SurveyFile } from "./helpers/types";
 import { getUserAsync, User, clearUserAsync } from "./helpers/user";
@@ -39,6 +40,9 @@ export default class RootScreen extends React.Component<
     const user = await getUserAsync();
     if (user) {
       const survey = await getSurveyFileAsync();
+
+      await connectDatabaseAsync(survey.studyInfo.id);
+
       this.setState({ survey });
     }
     this.setState({ userInfo: user, isLoading: false });