Skip to content

Commit 683cdc7

Browse files
committed
Newline formatting.
1 parent 61bffc8 commit 683cdc7

File tree

17 files changed

+0
-29
lines changed

17 files changed

+0
-29
lines changed

PowerSync/PowerSync.Common/Client/PowerSyncDatabase.cs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@ public class OpenFactorySource(ISQLOpenFactory Factory) : DatabaseSource
4040
public ISQLOpenFactory Factory { get; init; } = Factory;
4141
}
4242

43-
4443
public class PowerSyncDatabaseOptions() : BasePowerSyncDatabaseOptions()
4544
{
4645
/// <summary>
@@ -566,8 +565,6 @@ public async Task<T> WriteTransaction<T>(Func<ITransaction, Task<T>> fn, DBLockO
566565
return await Database.WriteTransaction(fn, options);
567566
}
568567

569-
570-
571568
/// <summary>
572569
/// Executes a read query every time the source tables are modified.
573570
/// <para />
@@ -633,7 +630,6 @@ public async Task<string[]> ResolveTables(string sql, object[]? parameters = nul
633630
.Select(row => row.p2)
634631
.ToList();
635632

636-
637633
var tables = await GetAll<TableSelectResult>(
638634
"SELECT DISTINCT tbl_name FROM sqlite_master WHERE rootpage IN (SELECT json_each.value FROM json_each(?))",
639635
[JsonConvert.SerializeObject(rootPages)]

PowerSync/PowerSync.Common/Client/Sync/Stream/Remote.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,6 @@ public async Task<T> Get<T>(string path, Dictionary<string, string>? headers = n
8787
return JsonConvert.DeserializeObject<T>(responseData)!;
8888
}
8989

90-
9190
public async IAsyncEnumerable<StreamingSyncLine?> PostStream(SyncStreamOptions options)
9291
{
9392
using var requestMessage = await BuildRequest(HttpMethod.Post, options.Path, options.Data, options.Headers);

PowerSync/PowerSync.Common/Client/Sync/Stream/StreamingSyncImplementation.cs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,6 @@ public class PowerSyncConnectionOptions(
9090
public int? CrudUploadThrottleMs { get; set; } = crudUploadThrottleMs;
9191
}
9292

93-
9493
public class StreamingSyncImplementation : EventStream<StreamingSyncImplementationEvent>
9594
{
9695
public static RequiredPowerSyncConnectionOptions DEFAULT_STREAM_CONNECTION_OPTIONS = new()
@@ -127,7 +126,6 @@ public StreamingSyncImplementation(StreamingSyncImplementationOptions options)
127126
}
128127
});
129128

130-
131129
locks = new StreamingSyncLocks();
132130
logger = options.Logger ?? NullLogger.Instance;
133131

@@ -168,7 +166,6 @@ public async Task Connect(PowerSyncConnectionOptions? options = null)
168166
}
169167
CancellationTokenSource = new CancellationTokenSource();
170168

171-
172169
streamingSyncTask = StreamingSync(CancellationTokenSource.Token, options);
173170

174171
var tcs = new TaskCompletionSource<bool>();

PowerSync/PowerSync.Common/Client/Sync/Stream/StreamingSyncTypes.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,6 @@ public class StreamingSyncKeepalive : StreamingSyncLine
135135
public int? TokenExpiresIn { get; set; }
136136
}
137137

138-
139138
public class CrudRequest
140139
{
141140
[JsonProperty("data")]

PowerSync/PowerSync.Common/DB/Crud/SyncStatus.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ public SyncStatusOptions(SyncStatusOptions options)
2424
HasSynced = options.HasSynced;
2525
}
2626

27-
2827
[JsonProperty("connected")]
2928
public bool? Connected { get; set; }
3029

@@ -66,7 +65,6 @@ public class SyncStatus(SyncStatusOptions options)
6665
/// </summary>
6766
public SyncDataFlowStatus DataFlowStatus => Options.DataFlow ?? new SyncDataFlowStatus();
6867

69-
7068
public bool IsEqual(SyncStatus status)
7169
{
7270
return JsonConvert.SerializeObject(Options) == JsonConvert.SerializeObject(status.Options);

PowerSync/PowerSync.Common/DB/Schema/IndexedColumn.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ public class IndexedColumn(IndexColumnOptions options)
1414

1515
protected bool Ascending { get; set; } = options.Ascending;
1616

17-
1817
public object ToJSON(Table table)
1918
{
2019
var colType = table.Columns.TryGetValue(Name, out var value) ? value : default;

PowerSync/PowerSync.Common/DB/Schema/Schema.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,6 @@ public string ToJSON()
2020
}).ToList()
2121
};
2222

23-
2423
return JsonConvert.SerializeObject(jsonObject);
2524
}
2625
}
27-

PowerSync/PowerSync.Common/DB/Schema/Table.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ namespace PowerSync.Common.DB.Schema;
55
// TODO CL Need to port this to C#
66
// export const InvalidSQLCharacters = /["'%,.#\s[\]]/;
77

8-
98
public class TableOptions(
109
Dictionary<string, List<string>>? indexes = null,
1110
bool? localOnly = null,
@@ -66,4 +65,3 @@ public string ToJSON(string Name = "")
6665
return JsonConvert.SerializeObject(jsonObject);
6766
}
6867
}
69-

PowerSync/PowerSync.Common/MDSQLite/MDSQLiteAdapter.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,6 @@ private async Task Init()
6363
writeConnection = await OpenConnection(options.Name);
6464
readConnection = await OpenConnection(options.Name);
6565

66-
6766
string[] baseStatements =
6867
[
6968
$"PRAGMA busy_timeout = {resolvedMDSQLiteOptions.LockTimeoutMs}",
@@ -79,7 +78,6 @@ private async Task Init()
7978
$"PRAGMA synchronous = {resolvedMDSQLiteOptions.Synchronous}",
8079
];
8180

82-
8381
string[] readConnectionStatements =
8482
[
8583
.. baseStatements,

PowerSync/PowerSync.Common/MDSQLite/MDSQLiteConnection.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,6 @@ public async Task<NonQueryResult> Execute(string query, object[]? parameters = n
127127
};
128128
}
129129

130-
131130
public async Task<QueryResult> ExecuteQuery(string query, object[]? parameters = null)
132131
{
133132
var result = new QueryResult();

0 commit comments

Comments
 (0)