mirror of https://github.com/Squidex/squidex.git
Browse Source
* Fix referencing queries and improve tests. * Another test. * Tests fixed. * Fix inputs * A few fixes * GraphQL subscription tests * Remove log. * Fix asset-selector naming.pull/947/head
Sebastian Stehle
4 years ago
committed by
GitHub
GitHub
60 changed files with 886 additions and 629 deletions
@ -0,0 +1,144 @@ |
|||
// ==========================================================================
|
|||
// Squidex Headless CMS
|
|||
// ==========================================================================
|
|||
// Copyright (c) Squidex UG (haftungsbeschraenkt)
|
|||
// All rights reserved. Licensed under the MIT license.
|
|||
// ==========================================================================
|
|||
|
|||
using System; |
|||
using System.Reactive.Linq; |
|||
using GraphQL; |
|||
using GraphQL.Client.Http; |
|||
using GraphQL.Client.Serializer.Newtonsoft; |
|||
using Squidex.ClientLibrary; |
|||
using Squidex.ClientLibrary.Management; |
|||
using TestSuite.Model; |
|||
|
|||
namespace TestSuite.ApiTests; |
|||
|
|||
#pragma warning disable SA1300 // Element should begin with upper-case letter
|
|||
#pragma warning disable SA1507 // Code should not contain multiple blank lines in a row
|
|||
|
|||
public class GraphQLSubscriptionTests : IClassFixture<ContentFixture> |
|||
{ |
|||
public ContentFixture _ { get; set; } |
|||
|
|||
public GraphQLSubscriptionTests(ContentFixture fixture) |
|||
{ |
|||
_ = fixture; |
|||
} |
|||
|
|||
private sealed class ContentChangesResult |
|||
{ |
|||
public ContentChanges ContentChanges { get; set; } |
|||
} |
|||
|
|||
private sealed class ContentChanges |
|||
{ |
|||
public string Id { get; set; } |
|||
} |
|||
|
|||
private sealed class AssetChangesResult |
|||
{ |
|||
public AssetChanges AssetChanges { get; set; } |
|||
} |
|||
|
|||
private sealed class AssetChanges |
|||
{ |
|||
public string Id { get; set; } |
|||
} |
|||
|
|||
[Fact] |
|||
public async Task Should_listen_to_content_changes() |
|||
{ |
|||
var client = await CreateClient(); |
|||
|
|||
|
|||
// STEP 1: Subscribe to changes.
|
|||
var contentChanges = new GraphQLRequest |
|||
{ |
|||
Query = @"
|
|||
subscription { |
|||
contentChanges { |
|||
id |
|||
} |
|||
}"
|
|||
}; |
|||
|
|||
var contentId = Guid.NewGuid().ToString(); |
|||
|
|||
var subscriptionStream |
|||
= client.CreateSubscriptionStream<ContentChangesResult>(contentChanges); |
|||
|
|||
var publishedContent = |
|||
subscriptionStream.Where(x => x.Data.ContentChanges.Id == contentId).Timeout(TimeSpan.FromSeconds(30)) |
|||
.FirstOrDefaultAsync(); |
|||
|
|||
|
|||
// STEP 2: Create Content.
|
|||
await _.Contents.CreateAsync(new TestEntityData(), new ContentCreateOptions { Id = contentId }); |
|||
|
|||
|
|||
// STEP 3: Wait for publication.
|
|||
var publishedResult = await publishedContent; |
|||
|
|||
Assert.Equal(contentId, publishedResult.Data.ContentChanges.Id); |
|||
} |
|||
|
|||
[Fact] |
|||
public async Task Should_listen_to_asset_changes() |
|||
{ |
|||
var client = await CreateClient(); |
|||
|
|||
|
|||
// STEP 1: Subscribe to changes.
|
|||
var assetChanges = new GraphQLRequest |
|||
{ |
|||
Query = @"
|
|||
subscription { |
|||
assetChanges { |
|||
id |
|||
} |
|||
}"
|
|||
}; |
|||
|
|||
var assetId = Guid.NewGuid().ToString(); |
|||
|
|||
var subscriptionStream |
|||
= client.CreateSubscriptionStream<AssetChangesResult>(assetChanges); |
|||
|
|||
var publishedAsset = |
|||
subscriptionStream.Where(x => x.Data.AssetChanges.Id == assetId).Timeout(TimeSpan.FromSeconds(30)) |
|||
.FirstOrDefaultAsync(); |
|||
|
|||
|
|||
// STEP 2: Create asset.
|
|||
var fileParameter = FileParameter.FromPath("Assets/SampleVideo_1280x720_1mb.mp4"); |
|||
|
|||
await using (fileParameter.Data) |
|||
{ |
|||
await _.Assets.UploadAssetAsync(_.AppName, fileParameter, new AssetUploadOptions { Id = assetId }); |
|||
} |
|||
|
|||
// STEP 3: Wait for publication.
|
|||
var publishedResult = await publishedAsset; |
|||
|
|||
Assert.Equal(assetId, publishedResult.Data.AssetChanges.Id); |
|||
} |
|||
|
|||
private async Task<GraphQLHttpClient> CreateClient() |
|||
{ |
|||
var accessToken = await _.ClientManager.Options.Authenticator.GetBearerTokenAsync(_.AppName, default); |
|||
|
|||
var options = new GraphQLHttpClientOptions |
|||
{ |
|||
EndPoint = new Uri(_.ClientManager.GenerateUrl($"/api/content/{_.AppName}/graphql?access_token={accessToken}")) |
|||
}; |
|||
|
|||
var client = new GraphQLHttpClient(options, new NewtonsoftJsonSerializer()); |
|||
|
|||
await client.InitializeWebsocketConnection(); |
|||
|
|||
return client; |
|||
} |
|||
} |
|||
@ -1,11 +1,20 @@ |
|||
<div #container> |
|||
<div #inner [class.fullscreen]="snapshot.isFullscreen"> |
|||
<iframe #iframe scrolling="no" width="100%" [style.height]="0" [attr.src]="computedUrl | sqxSafeResourceUrl"></iframe> |
|||
<div #inner [class.fullscreen]="snapshot.isFullscreen" [class.expanded]="isExpanded"> |
|||
<iframe #iframe [scrolling]="!isExpanded ? 'no' : 'yes'" width="100%" [style.height]="0" [attr.src]="computedUrl | sqxSafeResourceUrl"></iframe> |
|||
</div> |
|||
</div> |
|||
|
|||
<ng-container *sqxModal="assetsDialog"> |
|||
<sqx-assets-selector |
|||
<sqx-asset-selector |
|||
(select)="pickAssets($event)"> |
|||
</sqx-assets-selector> |
|||
</sqx-asset-selector> |
|||
</ng-container> |
|||
|
|||
<ng-container *sqxModal="contentsDialog"> |
|||
<sqx-content-selector |
|||
(select)="pickContents($event)" |
|||
[language]="language" |
|||
[languages]="languages" |
|||
[schemaNames]="contentsSchemas"> |
|||
</sqx-content-selector> |
|||
</ng-container> |
|||
|
|||
File diff suppressed because it is too large
Loading…
Reference in new issue