Skip to content

Commit 699696f

Browse files
committed
Fix #1459: add script file/id to update descriptors
1 parent e8a91e5 commit 699696f

File tree

2 files changed

+42
-0
lines changed

2 files changed

+42
-0
lines changed

src/Nest/DSL/Bulk/BulkUpdateDescriptor.cs

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,10 @@ public interface IBulkUpdateOperation<TDocument, TPartialDocument> : IBulkOperat
2020
string Lang { get; set; }
2121

2222
string Script { get; set; }
23+
24+
string ScriptId { get; set; }
25+
26+
string ScriptFile { get; set; }
2327

2428
Dictionary<string, object> Params { get; set; }
2529
}
@@ -88,6 +92,8 @@ public override object GetBody()
8892
public bool? DocAsUpsert { get; set; }
8993
public string Lang { get; set; }
9094
public string Script { get; set; }
95+
public string ScriptId { get; set; }
96+
public string ScriptFile { get; set; }
9197
public Dictionary<string, object> Params { get; set; }
9298
}
9399

@@ -112,6 +118,10 @@ public class BulkUpdateDescriptor<TDocument, TPartialDocument> : BulkOperationDe
112118

113119
string IBulkUpdateOperation<TDocument, TPartialDocument>.Script { get; set; }
114120

121+
string IBulkUpdateOperation<TDocument, TPartialDocument>.ScriptId { get; set; }
122+
123+
string IBulkUpdateOperation<TDocument, TPartialDocument>.ScriptFile { get; set; }
124+
115125
Dictionary<string, object> IBulkUpdateOperation<TDocument, TPartialDocument>.Params { get; set; }
116126

117127
protected override object GetBulkOperationBody()
@@ -225,6 +235,20 @@ public BulkUpdateDescriptor<TDocument, TPartialDocument> Script(string script)
225235
return this;
226236
}
227237

238+
public BulkUpdateDescriptor<TDocument, TPartialDocument> ScriptId(string scriptId)
239+
{
240+
scriptId.ThrowIfNull("scriptId");
241+
Self.ScriptId = scriptId;
242+
return this;
243+
}
244+
245+
public BulkUpdateDescriptor<TDocument, TPartialDocument> ScriptFile(string scriptFile)
246+
{
247+
scriptFile.ThrowIfNull("scriptFile");
248+
Self.ScriptFile = scriptFile;
249+
return this;
250+
}
251+
228252
public BulkUpdateDescriptor<TDocument, TPartialDocument> Params(Func<FluentDictionary<string, object>, FluentDictionary<string, object>> paramDictionary)
229253
{
230254
paramDictionary.ThrowIfNull("paramDictionary");

src/Nest/DSL/UpdateDescriptor.cs

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,12 @@ public interface IUpdateRequest<TDocument,TPartialDocument> : IDocumentOptionalP
1515
[JsonProperty(PropertyName = "script")]
1616
string Script { get; set; }
1717

18+
[JsonProperty(PropertyName = "script_id")]
19+
string ScriptId { get; set; }
20+
21+
[JsonProperty(PropertyName = "script_file")]
22+
string ScriptFile { get; set; }
23+
1824
[JsonProperty(PropertyName = "lang")]
1925
string Language { get; set; }
2026

@@ -87,6 +93,7 @@ protected override void UpdatePathInfo(IConnectionSettingsValues settings, Elast
8793

8894

8995
public string Script { get; set; }
96+
public string ScriptFile { get; set; }
9097
public string Language { get; set; }
9198
public Dictionary<string, object> Params { get; set; }
9299
public TDocument Upsert { get; set; }
@@ -104,6 +111,10 @@ public partial class UpdateDescriptor<TDocument,TPartialDocument>
104111
private IUpdateRequest<TDocument, TPartialDocument> Self { get { return this; } }
105112

106113
string IUpdateRequest<TDocument, TPartialDocument>.Script { get; set; }
114+
115+
string IUpdateRequest<TDocument, TPartialDocument>.ScriptId { get; set; }
116+
117+
string IUpdateRequest<TDocument, TPartialDocument>.ScriptFile { get; set; }
107118

108119
string IUpdateRequest<TDocument, TPartialDocument>.Language { get; set; }
109120

@@ -123,6 +134,13 @@ public UpdateDescriptor<TDocument, TPartialDocument> Script(string script)
123134
return this;
124135
}
125136

137+
public UpdateDescriptor<TDocument, TPartialDocument> ScriptFile(string scriptFile)
138+
{
139+
scriptFile.ThrowIfNull("scriptFile");
140+
Self.ScriptFile = scriptFile;
141+
return this;
142+
}
143+
126144
public UpdateDescriptor<TDocument, TPartialDocument> Params(Func<FluentDictionary<string, object>, FluentDictionary<string, object>> paramDictionary)
127145
{
128146
paramDictionary.ThrowIfNull("paramDictionary");

0 commit comments

Comments
 (0)