AMPLI-SYNC

h1. InitializeSubscriber Objective-C

<pre><code class="objc">

-(void)initializeSubscriber:(nonnull NSString*)subscriberId error:(NSError * _Nullable * _Nullable)error{

    NSString *requestUrlString = [NSString stringWithFormat:@"%@/InitializeSubscriber/%@", _serverURL, subscriberId];

    NSURL *requestURL = [NSURL URLWithString:requestUrlString];

    NSMutableURLRequest *request = [[NSMutableURLRequest alloc] init];

    [request setURL:requestURL];

    [request setHTTPMethod:@"GET"];

    NSHTTPURLResponse *response;

    NSData *data = [NSURLConnection sendSynchronousRequest:request returningResponse:&response error:error];

    if(!*error){

        switch (response.statusCode) {

            case 200:

                break;

            default:

                *error = [NSError errorWithDomain:@"com.sqlite-sync" code:0 userInfo:[NSDictionary dictionaryWithObject:[[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding] forKey:NSLocalizedDescriptionKey]];

                break;

        }

    }

    if(*error) return;

    NSDictionary* schema = [NSJSONSerialization JSONObjectWithData:data options:kNilOptions error:error];

    if(*error) return;

    NSArray *keys = [[schema allKeys] sortedArrayUsingComparator:^NSComparisonResult(id a, id b) { return [a compare:b]; }];

    sqlite3 *db;

    sqlite3_stmt *stmt = NULL;

    if(sqlite3_open([_databasePath UTF8String], &db) == SQLITE_OK){

        sqlite3_exec(db, "BEGIN TRANSACTION", 0, 0, 0);

        for (NSString* key in keys) {

            if(![key containsString:@"00000"]){

                if(sqlite3_prepare_v2(db, [[schema objectForKey:key] UTF8String], -1, &stmt, NULL) != SQLITE_OK

                   || sqlite3_step(stmt) != SQLITE_DONE){

                    *error = [NSError errorWithDomain:@"com.sqlite-sync" code:0 userInfo:[NSDictionary dictionaryWithObject:[NSString stringWithFormat:@"%s", sqlite3_errmsg(db)] forKey:NSLocalizedDescriptionKey]];

                    break;

                }

                sqlite3_reset(stmt);

            }

        }

        if(*error){

            sqlite3_exec(db, "ROLLBACK TRANSACTION", 0, 0, 0);

        }

        else{

            sqlite3_exec(db, "COMMIT", 0, 0, 0);

        }

        if(stmt){

            sqlite3_finalize(stmt);

        }

        sqlite3_close(db);

    }

    else{

        *error = [NSError errorWithDomain:@"com.sqlite-sync" code:0 userInfo:[NSDictionary dictionaryWithObject:@"Failed to open database" forKey:NSLocalizedDescriptionKey]];

    }

}

</code></pre>