1
#![allow(clippy::unwrap_used)]
2
#![allow(clippy::expect_used)]
3
use std::sync::{Arc, RwLock};
4
use ustr::Ustr;
5

            
6
use serde_json::Map as JsonMap;
7
use serde_json::Value;
8
use serde_json::Value as JsonValue;
9

            
10
use crate::ast::Moo;
11
use crate::ast::abstract_comprehension::AbstractComprehensionBuilder;
12
use crate::ast::ac_operators::ACOperatorKind;
13
use crate::ast::comprehension::ComprehensionBuilder;
14
use crate::ast::records::RecordValue;
15
use crate::ast::{
16
    AbstractLiteral, Atom, DeclarationPtr, Domain, Expression, FuncAttr, IntVal, JectivityAttr,
17
    Literal, MSetAttr, Name, PartialityAttr, Range, RecordEntry, SetAttr, SymbolTable,
18
    SymbolTablePtr,
19
};
20
use crate::ast::{DomainPtr, Metadata};
21
use crate::context::Context;
22
use crate::error::{Error, Result};
23
use crate::{Model, bug, error, into_matrix_expr, throw_error};
24

            
25
#[allow(unused_macros)]
26
macro_rules! parser_trace {
27
    ($($arg:tt)+) => {
28
        log::trace!(target:"jsonparser",$($arg)+)
29
    };
30
}
31

            
32
#[allow(unused_macros)]
33
macro_rules! parser_debug {
34
    ($($arg:tt)+) => {
35
        log::debug!(target:"jsonparser",$($arg)+)
36
    };
37
}
38

            
39
9958
pub fn model_from_json(str: &str, context: Arc<RwLock<Context<'static>>>) -> Result<Model> {
40
9958
    let mut m = Model::new(context);
41
9958
    let v: JsonValue = serde_json::from_str(str)?;
42
9958
    let statements = v["mStatements"]
43
9958
        .as_array()
44
9958
        .ok_or(error!("mStatements is not an array"))?;
45

            
46
29400
    for statement in statements {
47
29400
        let entry = statement
48
29400
            .as_object()
49
29400
            .ok_or(error!("mStatements contains a non-object"))?
50
29400
            .iter()
51
29400
            .next()
52
29400
            .ok_or(error!("mStatements contains an empty object"))?;
53

            
54
29400
        match entry.0.as_str() {
55
29400
            "Declaration" => {
56
20482
                let decl = entry
57
20482
                    .1
58
20482
                    .as_object()
59
20482
                    .ok_or(error!("Declaration is not an object".to_owned()))?;
60

            
61
                // One field in the declaration should tell us what kind it is.
62
                //
63
                // Find it, ignoring the other fields.
64
                //
65
                // e.g. FindOrGiven,
66

            
67
20482
                let mut valid_decl: bool = false;
68
20482
                let scope = m.symbols_ptr_unchecked().clone();
69
20482
                let model = &mut m;
70
20482
                for (kind, value) in decl {
71
20482
                    match kind.as_str() {
72
20482
                        "FindOrGiven" => {
73
18618
                            parse_variable(value, &mut model.symbols_mut())?;
74
18618
                            valid_decl = true;
75
18618
                            break;
76
                        }
77
1864
                        "Letting" => {
78
1864
                            parse_letting(value, &scope)?;
79
1844
                            valid_decl = true;
80
1844
                            break;
81
                        }
82
                        _ => continue,
83
                    }
84
                }
85

            
86
20462
                if !valid_decl {
87
                    throw_error!("Declaration is not a valid kind")?;
88
20462
                }
89
            }
90
8918
            "SuchThat" => {
91
8918
                let constraints_arr = match entry.1.as_array() {
92
8918
                    Some(x) => x,
93
                    None => bug!("SuchThat is not a vector"),
94
                };
95

            
96
8918
                let constraints: Vec<Expression> = constraints_arr
97
8918
                    .iter()
98
13518
                    .map(|x| parse_expression(x, m.symbols_ptr_unchecked()))
99
8918
                    .collect::<Result<Vec<_>>>()?;
100
8918
                m.add_constraints(constraints);
101
            }
102
            otherwise => bug!("Unhandled Statement {:#?}", otherwise),
103
        }
104
    }
105
9938
    Ok(m)
106
9958
}
107

            
108
35616
fn parse_variable(v: &JsonValue, symtab: &mut SymbolTable) -> Result<()> {
109
35616
    let arr = v.as_array().ok_or(error!("FindOrGiven is not an array"))?;
110
35616
    let name = arr[1]
111
35616
        .as_object()
112
35616
        .ok_or(error!("FindOrGiven[1] is not an object"))?["Name"]
113
35616
        .as_str()
114
35616
        .ok_or(error!("FindOrGiven[1].Name is not a string"))?;
115

            
116
35616
    let name = Name::User(Ustr::from(name));
117

            
118
35616
    let domain = arr[2]
119
35616
        .as_object()
120
35616
        .ok_or(error!("FindOrGiven[2] is not an object"))?
121
35616
        .iter()
122
35616
        .next()
123
35616
        .ok_or(error!("FindOrGiven[2] is an empty object"))?;
124

            
125
35616
    let domain = parse_domain(domain.0, domain.1, symtab)?;
126

            
127
35616
    symtab
128
35616
        .insert(DeclarationPtr::new_find(name.clone(), domain))
129
35616
        .ok_or(Error::Parse(format!(
130
35616
            "Could not add {name} to symbol table as it already exists"
131
35616
        )))
132
35616
}
133

            
134
3548
fn parse_letting(v: &JsonValue, scope: &SymbolTablePtr) -> Result<()> {
135
3548
    let arr = v.as_array().ok_or(error!("Letting is not an array"))?;
136
3548
    let name = arr[0]
137
3548
        .as_object()
138
3548
        .ok_or(error!("Letting[0] is not an object"))?["Name"]
139
3548
        .as_str()
140
3548
        .ok_or(error!("Letting[0].Name is not a string"))?;
141
3548
    let name = Name::User(Ustr::from(name));
142
    // value letting
143
3548
    if let Ok(value) = parse_expression(&arr[1], scope) {
144
2948
        let mut symtab = scope.write();
145
2948
        symtab
146
2948
            .insert(DeclarationPtr::new_value_letting(name.clone(), value))
147
2948
            .ok_or(Error::Parse(format!(
148
2948
                "Could not add {name} to symbol table as it already exists"
149
2948
            )))
150
    } else {
151
        // domain letting
152
600
        let domain = &arr[1]
153
600
            .as_object()
154
600
            .ok_or(error!("Letting[1] is not an object".to_owned()))?["Domain"]
155
600
            .as_object()
156
600
            .ok_or(error!("Letting[1].Domain is not an object"))?
157
600
            .iter()
158
600
            .next()
159
600
            .ok_or(error!("Letting[1].Domain is an empty object"))?;
160

            
161
600
        let mut symtab = scope.write();
162
600
        let domain = parse_domain(domain.0, domain.1, &mut symtab)?;
163

            
164
600
        symtab
165
600
            .insert(DeclarationPtr::new_domain_letting(name.clone(), domain))
166
600
            .ok_or(Error::Parse(format!(
167
600
                "Could not add {name} to symbol table as it already exists"
168
600
            )))
169
    }
170
3548
}
171

            
172
65776
fn parse_domain(
173
65776
    domain_name: &str,
174
65776
    domain_value: &JsonValue,
175
65776
    symbols: &mut SymbolTable,
176
65776
) -> Result<DomainPtr> {
177
65776
    match domain_name {
178
65776
        "DomainInt" => Ok(parse_int_domain(domain_value, symbols)?),
179
16028
        "DomainBool" => Ok(Domain::bool()),
180
7248
        "DomainReference" => {
181
1280
            let name = Name::user(
182
1280
                domain_value
183
1280
                    .as_array()
184
1280
                    .ok_or(error!("DomainReference is not an array"))?[0]
185
1280
                    .as_object()
186
1280
                    .ok_or(error!("DomainReference[0] is not an object"))?["Name"]
187
1280
                    .as_str()
188
1280
                    .ok_or(error!("DomainReference[0].Name is not a string"))?,
189
            );
190
1280
            let ptr = symbols
191
1280
                .lookup(&name)
192
1280
                .ok_or(error!(format!("Name {name} not found")))?;
193
1280
            let dom =
194
1280
                Domain::reference(ptr).ok_or(error!("Could not construct reference domain"))?;
195
1280
            Ok(dom)
196
        }
197
5968
        "DomainSet" => {
198
400
            let dom = domain_value.get(2).and_then(|v| v.as_object());
199
400
            let domain_obj = dom.ok_or(error!("DomainSet is missing domain object"))?;
200
400
            let domain = domain_obj
201
400
                .iter()
202
400
                .next()
203
400
                .ok_or(Error::Parse("DomainSet is an empty object".to_owned()))?;
204
400
            let domain = parse_domain(domain.0.as_str(), domain.1, symbols)?;
205
400
            let size = domain_value
206
400
                .get(1)
207
400
                .and_then(|v| v.as_object())
208
400
                .ok_or(error!("Set size attributes is not an object"))?;
209
400
            let size = parse_size_attr(size, symbols)?;
210
400
            let attr: SetAttr<IntVal> = SetAttr { size };
211
400
            Ok(Domain::set(attr, domain))
212
        }
213
5568
        "DomainMSet" => {
214
360
            let dom = domain_value
215
360
                .get(2)
216
360
                .and_then(|v| v.as_object())
217
360
                .expect("domain object exists");
218
360
            let domain = dom
219
360
                .iter()
220
360
                .next()
221
360
                .ok_or(Error::Parse("DomainMSet is an empty object".to_owned()))?;
222
360
            let domain = parse_domain(domain.0.as_str(), domain.1, symbols)?;
223

            
224
            // Parse Attributes
225
360
            let attributes = domain_value
226
360
                .get(1)
227
360
                .and_then(|v| v.as_array())
228
360
                .ok_or(error!("MSet attributes is not a json array"))?;
229

            
230
360
            let size = attributes
231
360
                .first()
232
360
                .and_then(|v| v.as_object())
233
360
                .ok_or(error!("MSet size attributes is not an object"))?;
234
360
            let size = parse_size_attr(size, symbols)?;
235

            
236
360
            let occurrence = attributes
237
360
                .get(1)
238
360
                .and_then(|v| v.as_object())
239
360
                .ok_or(error!("MSet occurrence attributes is not an object"))?;
240
360
            let occurrence = parse_occur_attr(occurrence, symbols)?;
241

            
242
360
            let attr: MSetAttr<IntVal> = MSetAttr { size, occurrence };
243
360
            Ok(Domain::mset(attr, domain))
244
        }
245

            
246
5208
        "DomainMatrix" => {
247
4368
            let domain_value = domain_value
248
4368
                .as_array()
249
4368
                .ok_or(error!("Domain matrix is not an array"))?;
250

            
251
4368
            let indexed_by_domain = domain_value[0].clone();
252
4368
            let (index_domain_name, index_domain_value) = indexed_by_domain
253
4368
                .as_object()
254
4368
                .ok_or(error!("DomainMatrix[0] is not an object"))?
255
4368
                .iter()
256
4368
                .next()
257
4368
                .ok_or(error!(""))?;
258

            
259
4368
            let (value_domain_name, value_domain_value) = domain_value[1]
260
4368
                .as_object()
261
4368
                .ok_or(error!(""))?
262
4368
                .iter()
263
4368
                .next()
264
4368
                .ok_or(error!(""))?;
265

            
266
            // Conjure stores a 2-d matrix as a matrix of a matrix.
267
            //
268
            // Therefore, the index is always a Domain.
269

            
270
4368
            let mut index_domains: Vec<DomainPtr> = vec![];
271

            
272
4368
            index_domains.push(parse_domain(
273
4368
                index_domain_name,
274
4368
                index_domain_value,
275
4368
                symbols,
276
            )?);
277

            
278
            // We want to store 2-d matrices as a matrix with two index domains, not a matrix in a
279
            // matrix.
280
            //
281
            // Walk through the value domain until it is not a DomainMatrix, adding the index to
282
            // our list of indices.
283
4368
            let mut value_domain = parse_domain(value_domain_name, value_domain_value, symbols)?;
284
5088
            while let Some((new_value_domain, mut indices)) = value_domain.as_matrix() {
285
720
                index_domains.append(&mut indices);
286
720
                value_domain = new_value_domain.clone()
287
            }
288

            
289
4368
            Ok(Domain::matrix(value_domain, index_domains))
290
        }
291
840
        "DomainTuple" => {
292
280
            let domain_value = domain_value
293
280
                .as_array()
294
280
                .ok_or(error!("Domain tuple is not an array"))?;
295

            
296
            //iterate through the array and parse each domain
297
280
            let domain = domain_value
298
280
                .iter()
299
560
                .map(|x| {
300
560
                    let domain = x
301
560
                        .as_object()
302
560
                        .ok_or(error!("DomainTuple[0] is not an object"))?
303
560
                        .iter()
304
560
                        .next()
305
560
                        .ok_or(error!("DomainTuple[0] is an empty object"))?;
306
560
                    parse_domain(domain.0, domain.1, symbols)
307
560
                })
308
280
                .collect::<Result<Vec<DomainPtr>>>()?;
309

            
310
280
            Ok(Domain::tuple(domain))
311
        }
312
560
        "DomainRecord" => {
313
40
            let domain_value = domain_value
314
40
                .as_array()
315
40
                .ok_or(error!("Domain Record is not a json array"))?;
316

            
317
40
            let mut record_entries = vec![];
318

            
319
80
            for item in domain_value {
320
                //collect the name of the record field
321
80
                let name = item[0]
322
80
                    .as_object()
323
80
                    .ok_or(error!("FindOrGiven[1] is not an object"))?["Name"]
324
80
                    .as_str()
325
80
                    .ok_or(error!("FindOrGiven[1].Name is not a string"))?;
326

            
327
80
                let name = Name::User(Ustr::from(name));
328
                // then collect the domain of the record field
329
80
                let domain = item[1]
330
80
                    .as_object()
331
80
                    .ok_or(error!("FindOrGiven[2] is not an object"))?
332
80
                    .iter()
333
80
                    .next()
334
80
                    .ok_or(error!("FindOrGiven[2] is an empty object"))?;
335

            
336
80
                let domain = parse_domain(domain.0, domain.1, symbols)?;
337

            
338
80
                let rec = RecordEntry { name, domain };
339

            
340
80
                record_entries.push(rec);
341
            }
342

            
343
            // add record fields to symbol table
344
80
            for decl in record_entries
345
40
                .iter()
346
40
                .cloned()
347
40
                .map(DeclarationPtr::new_record_field)
348
            {
349
80
                symbols.insert(decl).ok_or(error!(
350
                    "record field should not already be in the symbol table"
351
                ))?;
352
            }
353

            
354
40
            Ok(Domain::record(record_entries))
355
        }
356
520
        "DomainFunction" => {
357
520
            let domain = domain_value
358
520
                .get(2)
359
520
                .and_then(|v| v.as_object())
360
520
                .ok_or(error!("Function domain is not an object"))?;
361
520
            let domain = domain
362
520
                .iter()
363
520
                .next()
364
520
                .ok_or(Error::Parse("DomainSet is an empty object".to_owned()))?;
365
520
            let domain = parse_domain(domain.0.as_str(), domain.1, symbols)?;
366

            
367
520
            let codomain = domain_value
368
520
                .get(3)
369
520
                .and_then(|v| v.as_object())
370
520
                .ok_or(error!("Function codomain is not an object"))?;
371
520
            let codomain = codomain
372
520
                .iter()
373
520
                .next()
374
520
                .ok_or(Error::Parse("DomainSet is an empty object".to_owned()))?;
375
520
            let codomain = parse_domain(codomain.0.as_str(), codomain.1, symbols)?;
376

            
377
            // Attribute parsing
378
520
            let attributes = domain_value
379
520
                .get(1)
380
520
                .and_then(|v| v.as_array())
381
520
                .ok_or(error!("Function attributes is not a json array"))?;
382
520
            let size = attributes
383
520
                .first()
384
520
                .and_then(|v| v.as_object())
385
520
                .ok_or(error!("Function size attributes is not an object"))?;
386
520
            let size = parse_size_attr(size, symbols)?;
387
520
            let partiality = attributes
388
520
                .get(1)
389
520
                .and_then(|v| v.as_str())
390
520
                .ok_or(error!("Function partiality is not a string"))?;
391
520
            let partiality = match partiality {
392
520
                "PartialityAttr_Partial" => Some(PartialityAttr::Partial),
393
80
                "PartialityAttr_Total" => Some(PartialityAttr::Total),
394
                _ => None,
395
            };
396
520
            let partiality =
397
520
                partiality.ok_or(Error::Parse("Partiality is an unknown type".to_owned()))?;
398
520
            let jectivity = attributes
399
520
                .get(2)
400
520
                .and_then(|v| v.as_str())
401
520
                .ok_or(error!("Function jectivity is not a string"))?;
402
520
            let jectivity = match jectivity {
403
520
                "JectivityAttr_Injective" => Some(JectivityAttr::Injective),
404
440
                "JectivityAttr_Surjective" => Some(JectivityAttr::Surjective),
405
400
                "JectivityAttr_Bijective" => Some(JectivityAttr::Bijective),
406
360
                "JectivityAttr_None" => Some(JectivityAttr::None),
407
                _ => None,
408
            };
409
520
            let jectivity =
410
520
                jectivity.ok_or(Error::Parse("Jectivity is an unknown type".to_owned()))?;
411

            
412
520
            let attr: FuncAttr<IntVal> = FuncAttr {
413
520
                size,
414
520
                partiality,
415
520
                jectivity,
416
520
            };
417

            
418
520
            Ok(Domain::function(attr, domain, codomain))
419
        }
420
        _ => Err(Error::Parse(
421
            "FindOrGiven[2] is an unknown object".to_owned(), // consider covered
422
        )),
423
    }
424
65776
}
425

            
426
1280
fn parse_size_attr(
427
1280
    attr_map: &JsonMap<String, JsonValue>,
428
1280
    symbols: &mut SymbolTable,
429
1280
) -> Result<Range<IntVal>> {
430
1280
    let scope = SymbolTablePtr::new();
431
1280
    *scope.write() = symbols.clone();
432

            
433
1280
    let attr_obj = attr_map
434
1280
        .iter()
435
1280
        .next()
436
1280
        .ok_or(Error::Parse("SizeAttr is an empty object".to_owned()))?;
437
1280
    match attr_obj.0.as_str() {
438
1280
        "SizeAttr_None" => Ok(Range::Unbounded),
439
720
        "SizeAttr_MinSize" => {
440
360
            let size = parse_expression_to_int_val(attr_obj.1, &scope)?;
441
360
            Ok(Range::UnboundedR(size))
442
        }
443
360
        "SizeAttr_MaxSize" => {
444
112
            let size = parse_expression_to_int_val(attr_obj.1, &scope)?;
445
112
            Ok(Range::UnboundedL(size))
446
        }
447
248
        "SizeAttr_MinMaxSize" => {
448
128
            let min_max = attr_obj
449
128
                .1
450
128
                .as_array()
451
128
                .ok_or(error!("SizeAttr MinMaxSize is not a json array"))?;
452
128
            let min = min_max
453
128
                .first()
454
128
                .ok_or(error!("SizeAttr Min is not present"))?;
455
128
            let min_int = parse_expression_to_int_val(min, &scope)?;
456
128
            let max = min_max
457
128
                .get(1)
458
128
                .ok_or(error!("SizeAttr Max is not present"))?;
459
128
            let max_int = parse_expression_to_int_val(max, &scope)?;
460
128
            Ok(Range::Bounded(min_int, max_int))
461
        }
462
120
        "SizeAttr_Size" => {
463
120
            let size = parse_expression_to_int_val(attr_obj.1, &scope)?;
464
120
            Ok(Range::Single(size))
465
        }
466
        _ => Err(Error::Parse("SizeAttr is an unknown type".to_owned())),
467
    }
468
1280
}
469

            
470
360
fn parse_occur_attr(
471
360
    attr_map: &JsonMap<String, JsonValue>,
472
360
    symbols: &mut SymbolTable,
473
360
) -> Result<Range<IntVal>> {
474
360
    let scope = SymbolTablePtr::new();
475
360
    *scope.write() = symbols.clone();
476
360
    let attr_obj = attr_map
477
360
        .iter()
478
360
        .next()
479
360
        .ok_or(Error::Parse("OccurAttr is an empty object".to_owned()))?;
480
360
    match attr_obj.0.as_str() {
481
360
        "OccurAttr_None" => Ok(Range::Unbounded),
482
200
        "OccurAttr_MinOccur" => {
483
40
            let size_int = parse_expression_to_int_val(attr_obj.1, &scope)?;
484
40
            Ok(Range::UnboundedR(size_int))
485
        }
486
160
        "OccurAttr_MaxOccur" => {
487
80
            let size_int = parse_expression_to_int_val(attr_obj.1, &scope)?;
488
80
            Ok(Range::UnboundedL(size_int))
489
        }
490
80
        "OccurAttr_MinMaxOccur" => {
491
80
            let min_max = attr_obj
492
80
                .1
493
80
                .as_array()
494
80
                .ok_or(error!("OccurAttr MinMaxOccur is not a json array"))?;
495
80
            let min = min_max
496
80
                .first()
497
80
                .ok_or(error!("OccurAttr Min is not present"))?;
498
80
            let min_int = parse_expression_to_int_val(min, &scope)?;
499
80
            let max = min_max
500
80
                .get(1)
501
80
                .ok_or(error!("OccurAttr Max is not present"))?;
502
80
            let max_int = parse_expression_to_int_val(max, &scope)?;
503
80
            Ok(Range::Bounded(min_int, max_int))
504
        }
505
        "OccurAttr_Size" => {
506
            let size_int = parse_expression_to_int_val(attr_obj.1, &scope)?;
507
            Ok(Range::Single(size_int))
508
        }
509
        _ => Err(Error::Parse("OccurAttr is an unknown type".to_owned())),
510
    }
511
360
}
512

            
513
49748
fn parse_int_domain(v: &JsonValue, symbols: &SymbolTable) -> Result<DomainPtr> {
514
49748
    let scope = SymbolTablePtr::new();
515
49748
    *scope.write() = symbols.clone();
516

            
517
49748
    let mut ranges = Vec::new();
518
49748
    let arr = v
519
49748
        .as_array()
520
49748
        .ok_or(error!("DomainInt is not an array".to_owned()))?[1]
521
49748
        .as_array()
522
49748
        .ok_or(error!("DomainInt[1] is not an array".to_owned()))?;
523
51908
    for range in arr {
524
51908
        let range = range
525
51908
            .as_object()
526
51908
            .ok_or(error!("DomainInt[1] contains a non-object"))?
527
51908
            .iter()
528
51908
            .next()
529
51908
            .ok_or(error!("DomainInt[1] contains an empty object"))?;
530
51908
        match range.0.as_str() {
531
51908
            "RangeBounded" => {
532
48428
                let arr = range
533
48428
                    .1
534
48428
                    .as_array()
535
48428
                    .ok_or(error!("RangeBounded is not an array".to_owned()))?;
536
48428
                let mut nums = Vec::new();
537
96856
                for item in arr.iter() {
538
96856
                    let num = parse_expression_to_int_val(item, &scope)?;
539
96856
                    nums.push(num);
540
                }
541
48428
                let lower = nums
542
48428
                    .first()
543
48428
                    .cloned()
544
48428
                    .ok_or(error!("RangeBounded lower bound missing"))?;
545
48428
                let upper = nums
546
48428
                    .get(1)
547
48428
                    .cloned()
548
48428
                    .ok_or(error!("RangeBounded upper bound missing"))?;
549
48428
                ranges.push(Range::Bounded(lower, upper));
550
            }
551
3480
            "RangeSingle" => {
552
3480
                let num = parse_expression_to_int_val(range.1, &scope)?;
553
3480
                ranges.push(Range::Single(num));
554
            }
555
            _ => return throw_error!("DomainInt[1] contains an unknown object"),
556
        }
557
    }
558
49748
    Ok(Domain::int(ranges))
559
49748
}
560

            
561
101464
fn parse_expression_to_int_val(obj: &JsonValue, scope: &SymbolTablePtr) -> Result<IntVal> {
562
101464
    parser_trace!("trying to parse domain value as expression: {}", obj);
563
101464
    let expr = parse_expression(obj, scope)?;
564

            
565
101464
    if let Some(Literal::Int(i)) = expr.clone().into_literal() {
566
98512
        return Ok(IntVal::Const(i));
567
2952
    }
568

            
569
1832
    if let Expression::Atomic(_, Atom::Reference(reference)) = &expr
570
1832
        && let Some(reference_val) = IntVal::new_ref(reference)
571
    {
572
1832
        return Ok(reference_val);
573
1120
    }
574

            
575
1120
    IntVal::new_expr(Moo::new(expr)).ok_or(error!("Could not parse integer expression"))
576
101464
}
577

            
578
type BinOp = fn(Metadata, Moo<Expression>, Moo<Expression>) -> Expression;
579
type UnaryOp = fn(Metadata, Moo<Expression>) -> Expression;
580

            
581
96608
fn binary_operator(op_name: &str) -> Option<BinOp> {
582
96608
    match op_name {
583
96608
        "MkOpIn" => Some(Expression::In),
584
96048
        "MkOpUnion" => Some(Expression::Union),
585
95768
        "MkOpIntersect" => Some(Expression::Intersect),
586
95488
        "MkOpSupset" => Some(Expression::Supset),
587
95168
        "MkOpSupsetEq" => Some(Expression::SupsetEq),
588
94848
        "MkOpSubset" => Some(Expression::Subset),
589
94448
        "MkOpSubsetEq" => Some(Expression::SubsetEq),
590
94104
        "MkOpEq" => Some(Expression::Eq),
591
67592
        "MkOpNeq" => Some(Expression::Neq),
592
62264
        "MkOpGeq" => Some(Expression::Geq),
593
59624
        "MkOpLeq" => Some(Expression::Leq),
594
53752
        "MkOpGt" => Some(Expression::Gt),
595
51744
        "MkOpLt" => Some(Expression::Lt),
596
47888
        "MkOpLexLt" => Some(Expression::LexLt),
597
47248
        "MkOpLexGt" => Some(Expression::LexGt),
598
47248
        "MkOpLexLeq" => Some(Expression::LexLeq),
599
46288
        "MkOpLexGeq" => Some(Expression::LexGeq),
600
46288
        "MkOpDiv" => Some(Expression::UnsafeDiv),
601
41648
        "MkOpMod" => Some(Expression::UnsafeMod),
602
39648
        "MkOpMinus" => Some(Expression::Minus),
603
36360
        "MkOpImply" => Some(Expression::Imply),
604
32736
        "MkOpIff" => Some(Expression::Iff),
605
32336
        "MkOpPow" => Some(Expression::UnsafePow),
606
29808
        "MkOpImage" => Some(Expression::Image),
607
29728
        "MkOpImageSet" => Some(Expression::ImageSet),
608
29648
        "MkOpPreImage" => Some(Expression::PreImage),
609
29568
        "MkOpInverse" => Some(Expression::Inverse),
610
29488
        "MkOpRestrict" => Some(Expression::Restrict),
611
29408
        _ => None,
612
    }
613
96608
}
614

            
615
58816
fn unary_operator(op_name: &str) -> Option<UnaryOp> {
616
58816
    match op_name {
617
58816
        "MkOpNot" => Some(Expression::Not),
618
54976
        "MkOpNegate" => Some(Expression::Neg),
619
36976
        "MkOpTwoBars" => Some(Expression::Abs),
620
35856
        "MkOpAnd" => Some(Expression::And),
621
27968
        "MkOpSum" => Some(Expression::Sum),
622
16976
        "MkOpProduct" => Some(Expression::Product),
623
14096
        "MkOpOr" => Some(Expression::Or),
624
8560
        "MkOpMin" => Some(Expression::Min),
625
6480
        "MkOpMax" => Some(Expression::Max),
626
4480
        "MkOpAllDiff" => Some(Expression::AllDiff),
627
480
        "MkOpToInt" => Some(Expression::ToInt),
628
160
        "MkOpDefined" => Some(Expression::Defined),
629
80
        "MkOpRange" => Some(Expression::Range),
630
        _ => None,
631
    }
632
58816
}
633

            
634
288000
pub fn parse_expression(obj: &JsonValue, scope: &SymbolTablePtr) -> Result<Expression> {
635
288000
    let fail = |stage: &str| -> Error {
636
1000
        Error::Parse(format!(
637
1000
            "Could not parse expression at stage `{stage}` for json `{obj}`"
638
1000
        ))
639
1000
    };
640

            
641
680
    match obj {
642
287600
        Value::Object(op) if op.contains_key("Op") => {
643
75176
            let op_obj = op
644
75176
                .get("Op")
645
75176
                .and_then(Value::as_object)
646
75176
                .ok_or_else(|| fail("Op.as_object"))?;
647
75176
            let (op_name, _) = op_obj.iter().next().ok_or_else(|| fail("Op.iter().next"))?;
648

            
649
75176
            if op_obj.contains_key("MkOpFlatten") {
650
400
                parse_flatten_op(op_obj, scope)
651
74776
            } else if op_obj.contains_key("MkOpTable") {
652
120
                parse_table_op(op_obj, scope)
653
74656
            } else if op_obj.contains_key("MkOpIndexing") || op_obj.contains_key("MkOpSlicing") {
654
11648
                parse_indexing_slicing_op(op_obj, scope)
655
63008
            } else if binary_operator(op_name).is_some() {
656
33600
                parse_bin_op(op_obj, scope)
657
29408
            } else if unary_operator(op_name).is_some() {
658
29408
                parse_unary_op(op_obj, scope)
659
            } else {
660
                Err(fail("Op.unknown"))
661
            }
662
        }
663
212424
        Value::Object(comprehension) if comprehension.contains_key("Comprehension") => {
664
            parse_comprehension(comprehension, scope.clone(), None)
665
        }
666
212424
        Value::Object(refe) if refe.contains_key("Reference") => {
667
59892
            let ref_arr = refe["Reference"]
668
59892
                .as_array()
669
59892
                .ok_or_else(|| fail("Reference.as_array"))?;
670
59892
            let ref_obj = ref_arr
671
59892
                .first()
672
59892
                .and_then(|x| x.as_object())
673
59892
                .ok_or_else(|| fail("Reference[0].as_object"))?;
674
59892
            let name = ref_obj
675
59892
                .get("Name")
676
59892
                .and_then(|x| x.as_str())
677
59892
                .ok_or_else(|| fail("Reference[0].Name.as_str"))?;
678
59892
            let user_name = Name::User(Ustr::from(name));
679

            
680
59892
            let declaration: DeclarationPtr = scope
681
59892
                .read()
682
59892
                .lookup(&user_name)
683
59892
                .ok_or_else(|| fail("Reference.lookup"))?;
684

            
685
59892
            Ok(Expression::Atomic(
686
59892
                Metadata::new(),
687
59892
                Atom::Reference(crate::ast::Reference::new(declaration)),
688
59892
            ))
689
        }
690
152532
        Value::Object(abslit) if abslit.contains_key("AbstractLiteral") => {
691
12280
            let abstract_literal = abslit["AbstractLiteral"]
692
12280
                .as_object()
693
12280
                .ok_or_else(|| fail("AbstractLiteral.as_object"))?;
694

            
695
12280
            if abstract_literal.contains_key("AbsLitSet") {
696
80
                parse_abs_lit(&abslit["AbstractLiteral"]["AbsLitSet"], scope)
697
12200
            } else if abstract_literal.contains_key("AbsLitFunction") {
698
40
                parse_abs_function(&abslit["AbstractLiteral"]["AbsLitFunction"], scope)
699
12160
            } else if abstract_literal.contains_key("AbsLitMSet") {
700
                parse_abs_mset(&abslit["AbstractLiteral"]["AbsLitMSet"], scope)
701
            } else {
702
12160
                parse_abstract_matrix_as_expr(obj, scope)
703
            }
704
        }
705

            
706
140252
        Value::Object(constant) if constant.contains_key("Constant") => {
707
125492
            parse_constant(constant, scope).or_else(|_| parse_abstract_matrix_as_expr(obj, scope))
708
        }
709

            
710
14760
        Value::Object(constant) if constant.contains_key("ConstantAbstract") => {
711
680
            parse_abstract_matrix_as_expr(obj, scope)
712
        }
713

            
714
14080
        Value::Object(constant) if constant.contains_key("ConstantInt") => {
715
13400
            parse_constant(constant, scope)
716
        }
717
680
        Value::Object(constant) if constant.contains_key("ConstantBool") => {
718
80
            parse_constant(constant, scope)
719
        }
720

            
721
1000
        _ => Err(fail("no_match")),
722
    }
723
288000
}
724

            
725
2280
fn parse_abs_lit(abs_set: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
726
2280
    let values = abs_set
727
2280
        .as_array()
728
2280
        .ok_or(error!("AbsLitSet is not an array"))?;
729
2280
    let expressions = values
730
2280
        .iter()
731
5840
        .map(|values| parse_expression(values, scope))
732
2280
        .collect::<Result<Vec<_>>>()?;
733

            
734
2280
    Ok(Expression::AbstractLiteral(
735
2280
        Metadata::new(),
736
2280
        AbstractLiteral::Set(expressions),
737
2280
    ))
738
2280
}
739

            
740
40
fn parse_abs_mset(abs_mset: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
741
40
    let values = abs_mset
742
40
        .as_array()
743
40
        .ok_or(error!("AbsLitMSet is not an array"))?;
744
40
    let expressions = values
745
40
        .iter()
746
120
        .map(|values| parse_expression(values, scope))
747
40
        .collect::<Result<Vec<_>>>()?;
748

            
749
40
    Ok(Expression::AbstractLiteral(
750
40
        Metadata::new(),
751
40
        AbstractLiteral::MSet(expressions),
752
40
    ))
753
40
}
754

            
755
160
fn parse_abs_tuple(abs_tuple: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
756
160
    let values = abs_tuple
757
160
        .as_array()
758
160
        .ok_or(error!("AbsLitTuple is not an array"))?;
759
160
    let expressions = values
760
160
        .iter()
761
400
        .map(|values| parse_expression(values, scope))
762
160
        .collect::<Result<Vec<_>>>()?;
763

            
764
160
    Ok(Expression::AbstractLiteral(
765
160
        Metadata::new(),
766
160
        AbstractLiteral::Tuple(expressions),
767
160
    ))
768
160
}
769

            
770
//parses an abstract record as an expression
771
40
fn parse_abs_record(abs_record: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
772
40
    let entries = abs_record
773
40
        .as_array()
774
40
        .ok_or(error!("AbsLitRecord is not an array"))?;
775
40
    let mut rec = vec![];
776

            
777
80
    for entry in entries {
778
80
        let entry = entry
779
80
            .as_array()
780
80
            .ok_or(error!("AbsLitRecord entry is not an array"))?;
781
80
        let name = entry[0]
782
80
            .as_object()
783
80
            .ok_or(error!("AbsLitRecord field name is not an object"))?["Name"]
784
80
            .as_str()
785
80
            .ok_or(error!("AbsLitRecord field name is not a string"))?;
786

            
787
80
        let value = parse_expression(&entry[1], scope)?;
788

            
789
80
        let name = Name::User(Ustr::from(name));
790
80
        let rec_entry = RecordValue {
791
80
            name: name.clone(),
792
80
            value,
793
80
        };
794
80
        rec.push(rec_entry);
795
    }
796

            
797
40
    Ok(Expression::AbstractLiteral(
798
40
        Metadata::new(),
799
40
        AbstractLiteral::Record(rec),
800
40
    ))
801
40
}
802

            
803
//parses an abstract function as an expression
804
120
fn parse_abs_function(abs_function: &Value, scope: &SymbolTablePtr) -> Result<Expression> {
805
120
    let entries = abs_function
806
120
        .as_array()
807
120
        .ok_or(error!("AbsLitFunction is not an array"))?;
808
120
    let mut assignments = vec![];
809

            
810
240
    for entry in entries {
811
240
        let entry = entry
812
240
            .as_array()
813
240
            .ok_or(error!("Explicit function assignment is not an array"))?;
814
240
        let expression = entry
815
240
            .iter()
816
480
            .map(|values| parse_expression(values, scope))
817
240
            .collect::<Result<Vec<_>>>()?;
818
240
        let domain_value = expression
819
240
            .first()
820
240
            .ok_or(error!("Invalid function domain"))?;
821
240
        let codomain_value = expression
822
240
            .get(1)
823
240
            .ok_or(error!("Invalid function codomain"))?;
824
240
        let tuple = (domain_value.clone(), codomain_value.clone());
825
240
        assignments.push(tuple);
826
    }
827
120
    Ok(Expression::AbstractLiteral(
828
120
        Metadata::new(),
829
120
        AbstractLiteral::Function(assignments),
830
120
    ))
831
120
}
832

            
833
2084
fn parse_comprehension(
834
2084
    comprehension: &serde_json::Map<String, Value>,
835
2084
    scope: SymbolTablePtr,
836
2084
    comprehension_kind: Option<ACOperatorKind>,
837
2084
) -> Result<Expression> {
838
2084
    let fail = |stage: &str| -> Error {
839
        Error::Parse(format!("Could not parse comprehension at stage `{stage}`"))
840
    };
841

            
842
2084
    let value = &comprehension["Comprehension"];
843
2084
    let mut comprehension = ComprehensionBuilder::new(scope.clone());
844
2084
    let generator_symboltable = comprehension.generator_symboltable();
845
2084
    let return_expr_symboltable = comprehension.return_expr_symboltable();
846

            
847
2084
    let generators_and_guards_array = value
848
2084
        .pointer("/1")
849
2084
        .and_then(Value::as_array)
850
2084
        .ok_or_else(|| fail("Comprehension.pointer(/1).as_array"))?;
851
2084
    let generators_and_guards = generators_and_guards_array.iter();
852

            
853
2612
    for gen_or_guard in generators_and_guards {
854
2612
        let gen_or_guard_obj = gen_or_guard
855
2612
            .as_object()
856
2612
            .ok_or_else(|| fail("generator_or_guard.as_object"))?;
857
2612
        let (name, inner) = gen_or_guard_obj
858
2612
            .iter()
859
2612
            .next()
860
2612
            .ok_or_else(|| fail("generator_or_guard.iter().next"))?;
861
2612
        comprehension = match name.as_str() {
862
2612
            "Generator" => {
863
                // TODO: more things than GenDomainNoRepr and Single names here?
864
2312
                let generator_obj = inner
865
2312
                    .as_object()
866
2312
                    .ok_or_else(|| fail("Generator.inner.as_object"))?;
867
2312
                let (name, gen_inner) = generator_obj
868
2312
                    .iter()
869
2312
                    .next()
870
2312
                    .ok_or_else(|| fail("Generator.inner.iter().next"))?;
871
2312
                match name.as_str() {
872
2312
                    "GenDomainNoRepr" => {
873
2292
                        let name = gen_inner
874
2292
                            .pointer("/0/Single/Name")
875
2292
                            .and_then(Value::as_str)
876
2292
                            .ok_or_else(|| {
877
                                fail("GenDomainNoRepr.pointer(/0/Single/Name).as_str")
878
                            })?;
879
2292
                        let domain_obj = gen_inner
880
2292
                            .pointer("/1")
881
2292
                            .and_then(Value::as_object)
882
2292
                            .ok_or_else(|| fail("GenDomainNoRepr.pointer(/1).as_object"))?;
883
2292
                        let (domain_name, domain_value) = domain_obj
884
2292
                            .iter()
885
2292
                            .next()
886
2292
                            .ok_or_else(|| fail("GenDomainNoRepr.domain.iter().next"))?;
887
2292
                        let domain = parse_domain(
888
2292
                            domain_name,
889
2292
                            domain_value,
890
2292
                            &mut generator_symboltable.write(),
891
                        )?;
892
2292
                        comprehension.generator(DeclarationPtr::new_find(name.into(), domain))
893
                    }
894
                    // TODO: this is temporary until comprehensions support "in expr" generators
895
                    // currently only supports a single generator of this type
896
20
                    "GenInExpr" => return parse_in_expr_comprehension(scope, value, gen_inner),
897
                    _ => {
898
                        bug!("unknown generator type inside comprehension {name}");
899
                    }
900
                }
901
            }
902

            
903
300
            "Condition" => {
904
300
                let expr = parse_expression(inner, &generator_symboltable)
905
300
                    .map_err(|_| fail("Condition.parse_expression"))?;
906
300
                comprehension.guard(expr)
907
            }
908

            
909
            x => {
910
                bug!("unknown field inside comprehension {x}");
911
            }
912
        }
913
    }
914

            
915
2064
    let return_expr_value = value
916
2064
        .pointer("/0")
917
2064
        .ok_or_else(|| fail("Comprehension.pointer(/0)"))?;
918
2064
    let expr = parse_expression(return_expr_value, &return_expr_symboltable)
919
2064
        .map_err(|_| fail("Comprehension.return_expr.parse_expression"))?;
920

            
921
2064
    Ok(Expression::Comprehension(
922
2064
        Metadata::new(),
923
2064
        Moo::new(comprehension.with_return_value(expr, comprehension_kind)),
924
2064
    ))
925
2084
}
926

            
927
40
fn parse_in_expr_comprehension(
928
40
    scope: SymbolTablePtr,
929
40
    comprehension_value: &Value,
930
40
    gen_inner: &Value,
931
40
) -> Result<Expression> {
932
40
    let fail = |stage: &str| -> Error {
933
        Error::Parse(format!(
934
            "Could not parse GenInExpr comprehension at stage `{stage}`"
935
        ))
936
    };
937

            
938
40
    let name = gen_inner
939
40
        .pointer("/0/Single/Name")
940
40
        .and_then(Value::as_str)
941
40
        .ok_or_else(|| fail("GenInExpr.pointer(/0/Single/Name).as_str"))?;
942
40
    let generator_expr = gen_inner
943
40
        .pointer("/1")
944
40
        .ok_or_else(|| fail("GenInExpr.pointer(/1)"))?;
945
40
    let expr =
946
40
        parse_expression(generator_expr, &scope).map_err(|_| fail("GenInExpr.parse_expression"))?;
947

            
948
40
    let comprehension =
949
40
        AbstractComprehensionBuilder::new(&scope).new_expression_generator(expr, name.into());
950
40
    let return_expr_value = comprehension_value
951
40
        .pointer("/0")
952
40
        .ok_or_else(|| fail("comprehension_value.pointer(/0)"))?;
953
40
    let expr = parse_expression(return_expr_value, &comprehension.return_expr_symbols())
954
40
        .map_err(|_| fail("GenInExpr.return_expr.parse_expression"))?;
955

            
956
40
    Ok(Expression::AbstractComprehension(
957
40
        Metadata::new(),
958
40
        Moo::new(comprehension.with_return_value(expr)),
959
40
    ))
960
40
}
961

            
962
33600
fn parse_bin_op(
963
33600
    bin_op: &serde_json::Map<String, Value>,
964
33600
    scope: &SymbolTablePtr,
965
33600
) -> Result<Expression> {
966
    // we know there is a single key value pair in this object
967
    // extract the value, ignore the key
968
33600
    let (key, value) = bin_op
969
33600
        .into_iter()
970
33600
        .next()
971
33600
        .ok_or(error!("Binary op object is empty"))?;
972

            
973
33600
    let constructor = binary_operator(key.as_str())
974
33600
        .ok_or(error!(format!("Unknown binary operator `{}`", key)))?;
975

            
976
33600
    match &value {
977
33600
        Value::Array(bin_op_args) if bin_op_args.len() == 2 => {
978
33600
            let arg1 = parse_expression(&bin_op_args[0], scope)?;
979
33600
            let arg2 = parse_expression(&bin_op_args[1], scope)?;
980
33600
            Ok(constructor(Metadata::new(), Moo::new(arg1), Moo::new(arg2)))
981
        }
982
        _ => Err(error!("Binary operator arguments are not a 2-array")),
983
    }
984
33600
}
985

            
986
120
fn parse_table_op(
987
120
    op: &serde_json::Map<String, Value>,
988
120
    scope: &SymbolTablePtr,
989
120
) -> Result<Expression> {
990
120
    let args = op
991
120
        .get("MkOpTable")
992
120
        .ok_or(error!("MkOpTable missing"))?
993
120
        .as_array()
994
120
        .ok_or(error!("MkOpTable is not an array"))?;
995

            
996
120
    if args.len() != 2 {
997
        return Err(error!("MkOpTable arguments are not a 2-array"));
998
120
    }
999

            
120
    let tuple_expr = parse_expression(&args[0], scope)?;
120
    let allowed_rows_expr = parse_expression(&args[1], scope)?;
120
    let (tuple_elems, _) = tuple_expr
120
        .clone()
120
        .unwrap_matrix_unchecked()
120
        .ok_or(error!("MkOpTable first argument is not a matrix"))?;
120
    let (allowed_rows, _) = allowed_rows_expr
120
        .clone()
120
        .unwrap_matrix_unchecked()
120
        .ok_or(error!("MkOpTable second argument is not a matrix"))?;
320
    for row_expr in allowed_rows {
320
        let (row_elems, _) = row_expr
320
            .unwrap_matrix_unchecked()
320
            .ok_or(error!("MkOpTable row is not a matrix"))?;
320
        if row_elems.len() != tuple_elems.len() {
            return Err(error!("MkOpTable row width does not match tuple width"));
320
        }
    }
120
    Ok(Expression::Table(
120
        Metadata::new(),
120
        Moo::new(tuple_expr),
120
        Moo::new(allowed_rows_expr),
120
    ))
120
}
11648
fn parse_indexing_slicing_op(
11648
    op: &serde_json::Map<String, Value>,
11648
    scope: &SymbolTablePtr,
11648
) -> Result<Expression> {
    // we know there is a single key value pair in this object
    // extract the value, ignore the key
11648
    let (key, value) = op
11648
        .into_iter()
11648
        .next()
11648
        .ok_or(error!("Indexing/Slicing op object is empty"))?;
    // we know that this is meant to be a mkopindexing, so anything that goes wrong from here is a
    // bug!
    // Conjure does a[1,2,3] as MkOpIndexing(MkOpIndexing(MkOpIndexing(a,3),2),1).
    //
    // And  a[1,..,3] as MkOpIndexing(MkOpSlicing(MkOpIndexing(a,3)),1).
    //
    // However, we want this in a flattened form: Index(a, [1,2,3])
    let mut target: Expression;
11648
    let mut indices: Vec<Option<Expression>> = vec![];
    // true if this has no slicing, false otherwise.
11648
    let mut all_known = true;
11648
    match key.as_str() {
11648
        "MkOpIndexing" => {
10208
            match &value {
10208
                Value::Array(op_args) if op_args.len() == 2 => {
10208
                    target = parse_expression(&op_args[0], scope)?;
10208
                    indices.push(Some(parse_expression(&op_args[1], scope)?));
                }
                _ => return Err(error!("Unknown object inside MkOpIndexing")),
            };
        }
1440
        "MkOpSlicing" => {
1440
            all_known = false;
1440
            match &value {
1440
                Value::Array(op_args) if op_args.len() == 3 => {
1440
                    target = parse_expression(&op_args[0], scope)?;
1440
                    indices.push(None);
                }
                _ => return Err(error!("Unknown object inside MkOpSlicing")),
            };
        }
        _ => return Err(error!("Unknown indexing/slicing operator")),
    }
    loop {
15048
        match &mut target {
2920
            Expression::UnsafeIndex(_, new_target, new_indices) => {
2920
                indices.extend(new_indices.iter().cloned().rev().map(Some));
2920
                target = Moo::unwrap_or_clone(new_target.clone());
2920
            }
480
            Expression::UnsafeSlice(_, new_target, new_indices) => {
480
                all_known = false;
480
                indices.extend(new_indices.iter().cloned().rev());
480
                target = Moo::unwrap_or_clone(new_target.clone());
480
            }
            _ => {
                // not a slice or an index, we have reached the target.
11648
                break;
            }
        }
    }
11648
    indices.reverse();
11648
    if all_known {
        Ok(Expression::UnsafeIndex(
9728
            Metadata::new(),
9728
            Moo::new(target),
9728
            indices
9728
                .into_iter()
9728
                .collect::<Option<Vec<_>>>()
9728
                .ok_or(error!("Missing index in fully-known indexing operation"))?,
        ))
    } else {
1920
        Ok(Expression::UnsafeSlice(
1920
            Metadata::new(),
1920
            Moo::new(target),
1920
            indices,
1920
        ))
    }
11648
}
400
fn parse_flatten_op(
400
    op: &serde_json::Map<String, Value>,
400
    scope: &SymbolTablePtr,
400
) -> Result<Expression> {
400
    let args = op
400
        .get("MkOpFlatten")
400
        .ok_or(error!("MkOpFlatten missing"))?
400
        .as_array()
400
        .ok_or(error!("MkOpFlatten is not an array"))?;
400
    let first = args
400
        .first()
400
        .ok_or(error!("MkOpFlatten missing first argument"))?;
400
    let second = args
400
        .get(1)
400
        .ok_or(error!("MkOpFlatten missing second argument"))?;
400
    let n = parse_expression(first, scope).ok();
400
    let matrix = parse_expression(second, scope)?;
400
    if let Some(n) = n {
        Ok(Expression::Flatten(
            Metadata::new(),
            Some(Moo::new(n)),
            Moo::new(matrix),
        ))
    } else {
400
        Ok(Expression::Flatten(Metadata::new(), None, Moo::new(matrix)))
    }
400
}
29408
fn parse_unary_op(
29408
    un_op: &serde_json::Map<String, Value>,
29408
    scope: &SymbolTablePtr,
29408
) -> Result<Expression> {
29408
    let fail = |stage: &str| -> Error {
        Error::Parse(format!("Could not parse unary op at stage `{stage}`"))
    };
29408
    let (key, value) = un_op
29408
        .iter()
29408
        .next()
29408
        .ok_or_else(|| fail("un_op.iter().next"))?;
29408
    let constructor = unary_operator(key.as_str()).ok_or_else(|| fail("unary_operator"))?;
    // unops are the main things that contain comprehensions
    //
    // if the current expr is a quantifier like and/or/sum and it contains a comprehension, let the comprehension know what it is inside.
29408
    let arg = match value {
29408
        Value::Object(comprehension) if comprehension.contains_key("Comprehension") => {
4168
            let comprehension_kind = match key.as_str() {
4168
                "MkOpOr" => Some(ACOperatorKind::Or),
3248
                "MkOpAnd" => Some(ACOperatorKind::And),
800
                "MkOpSum" => Some(ACOperatorKind::Sum),
200
                "MkOpProduct" => Some(ACOperatorKind::Product),
200
                _ => None,
            };
4168
            parse_comprehension(comprehension, scope.clone(), comprehension_kind)
4168
                .map_err(|_| fail("value.Comprehension.parse_comprehension"))
        }
25240
        _ => parse_expression(value, scope).map_err(|_| fail("value.parse_expression")),
    }
29408
    .map_err(|_| fail("arg"))?;
29408
    Ok(constructor(Metadata::new(), Moo::new(arg)))
29408
}
// Takes in { AbstractLiteral: .... }
14760
fn parse_abstract_matrix_as_expr(
14760
    value: &serde_json::Value,
14760
    scope: &SymbolTablePtr,
14760
) -> Result<Expression> {
14760
    parser_trace!("trying to parse an abstract literal matrix");
13800
    let (values, domain_name, domain_value) =
14760
        if let Some(abs_lit_matrix) = value.pointer("/AbstractLiteral/AbsLitMatrix") {
12160
            parser_trace!(".. found JSON pointer /AbstractLiteral/AbstractLitMatrix");
12160
            let (domain_name, domain_value) = abs_lit_matrix
12160
                .pointer("/0")
12160
                .and_then(Value::as_object)
12160
                .and_then(|x| x.iter().next())
12160
                .ok_or(error!("AbsLitMatrix missing domain"))?;
12160
            let values = abs_lit_matrix
12160
                .pointer("/1")
12160
                .ok_or(error!("AbsLitMatrix missing values"))?;
12160
            Some((values, domain_name, domain_value))
        }
        // the input of this expression is constant - e.g. or([]), or([false]), min([2]), etc.
960
        else if let Some(const_abs_lit_matrix) =
2600
            value.pointer("/Constant/ConstantAbstract/AbsLitMatrix")
        {
960
            parser_trace!(".. found JSON pointer /Constant/ConstantAbstract/AbsLitMatrix");
960
            let (domain_name, domain_value) = const_abs_lit_matrix
960
                .pointer("/0")
960
                .and_then(Value::as_object)
960
                .and_then(|x| x.iter().next())
960
                .ok_or(error!("ConstantAbstract AbsLitMatrix missing domain"))?;
960
            let values = const_abs_lit_matrix
960
                .pointer("/1")
960
                .ok_or(error!("ConstantAbstract AbsLitMatrix missing values"))?;
960
            Some((values, domain_name, domain_value))
1640
        } else if let Some(const_abs_lit_matrix) = value.pointer("/ConstantAbstract/AbsLitMatrix") {
680
            parser_trace!(".. found JSON pointer /ConstantAbstract/AbsLitMatrix");
680
            let (domain_name, domain_value) = const_abs_lit_matrix
680
                .pointer("/0")
680
                .and_then(Value::as_object)
680
                .and_then(|x| x.iter().next())
680
                .ok_or(error!("ConstantAbstract/AbsLitMatrix missing domain"))?;
680
            let values = const_abs_lit_matrix
680
                .pointer("/1")
680
                .ok_or(error!("ConstantAbstract/AbsLitMatrix missing values"))?;
680
            Some((values, domain_name, domain_value))
        } else {
960
            None
        }
14760
        .ok_or(error!("Could not parse abstract literal matrix"))?;
13800
    parser_trace!(".. found in domain and values in JSON:");
13800
    parser_trace!(".. .. index domain name {domain_name}");
13800
    parser_trace!(".. .. values {value}");
13800
    let args_parsed = values
13800
        .as_array()
13800
        .ok_or(error!("Matrix values are not an array"))?
13800
        .iter()
29688
        .map(|x| parse_expression(x, scope))
13800
        .collect::<Result<Vec<Expression>>>()?;
13800
    if !args_parsed.is_empty() {
13760
        parser_trace!(
            ".. successfully parsed values as expressions: {}, ... ",
32
            args_parsed[0]
        );
    } else {
40
        parser_trace!(".. successfully parsed empty values ",);
    }
13800
    let mut symbols = scope.write();
13800
    match parse_domain(domain_name, domain_value, &mut symbols) {
13800
        Ok(domain) => {
13800
            parser_trace!("... sucessfully parsed domain as {domain}");
13800
            Ok(into_matrix_expr![args_parsed;domain])
        }
        Err(_) => {
            parser_trace!("... failed to parse domain, creating a matrix without one.");
            Ok(into_matrix_expr![args_parsed])
        }
    }
14760
}
138972
fn parse_constant(
138972
    constant: &serde_json::Map<String, Value>,
138972
    scope: &SymbolTablePtr,
138972
) -> Result<Expression> {
138972
    match &constant.get("Constant") {
125492
        Some(Value::Object(int)) if int.contains_key("ConstantInt") => {
120952
            let int_32: i32 = match int["ConstantInt"]
120952
                .as_array()
120952
                .ok_or(error!("ConstantInt is not an array"))?[1]
120952
                .as_i64()
120952
                .ok_or(error!("ConstantInt does not contain int"))?
120952
                .try_into()
            {
120952
                Ok(x) => x,
                Err(_) => return Err(error!("ConstantInt cannot be represented as i32")),
            };
120952
            Ok(Expression::Atomic(
120952
                Metadata::new(),
120952
                Atom::Literal(Literal::Int(int_32)),
120952
            ))
        }
4540
        Some(Value::Object(b)) if b.contains_key("ConstantBool") => {
1060
            let b: bool = b["ConstantBool"]
1060
                .as_bool()
1060
                .ok_or(error!("ConstantBool does not contain bool"))?;
1060
            Ok(Expression::Atomic(
1060
                Metadata::new(),
1060
                Atom::Literal(Literal::Bool(b)),
1060
            ))
        }
3480
        Some(Value::Object(int)) if int.contains_key("ConstantAbstract") => {
3480
            if let Some(Value::Object(obj)) = int.get("ConstantAbstract") {
3480
                if let Some(arr) = obj.get("AbsLitSet") {
2200
                    return parse_abs_lit(arr, scope);
1280
                } else if let Some(arr) = obj.get("AbsLitMSet") {
40
                    return parse_abs_mset(arr, scope);
1240
                } else if let Some(arr) = obj.get("AbsLitMatrix") {
960
                    return parse_abstract_matrix_as_expr(arr, scope);
280
                } else if let Some(arr) = obj.get("AbsLitTuple") {
160
                    return parse_abs_tuple(arr, scope);
120
                } else if let Some(arr) = obj.get("AbsLitRecord") {
40
                    return parse_abs_record(arr, scope);
80
                } else if let Some(arr) = obj.get("AbsLitFunction") {
80
                    return parse_abs_function(arr, scope);
                }
            }
            Err(error!("Unhandled ConstantAbstract literal type"))
        }
        // sometimes (e.g. constant matrices) we can have a ConstantInt / Constant bool that is
        // not wrapped in Constant
        None => {
13480
            let int_expr = constant
13480
                .get("ConstantInt")
13480
                .and_then(|x| x.as_array())
13480
                .and_then(|x| x[1].as_i64())
13480
                .and_then(|x| x.try_into().ok())
13480
                .map(|x| Expression::Atomic(Metadata::new(), Atom::Literal(Literal::Int(x))));
13480
            if let Some(expr) = int_expr {
13400
                return Ok(expr);
80
            }
80
            let bool_expr = constant
80
                .get("ConstantBool")
80
                .and_then(|x| x.as_bool())
80
                .map(|x| Expression::Atomic(Metadata::new(), Atom::Literal(Literal::Bool(x))));
80
            if let Some(expr) = bool_expr {
80
                return Ok(expr);
            }
            Err(error!(format!("Unhandled parse_constant {constant:#?}")))
        }
        otherwise => Err(error!(format!("Unhandled parse_constant {otherwise:#?}"))),
    }
138972
}